// Code generated by protoc-gen-go-binary. DO NOT EDIT. // source: proto/pbpeerstream/peerstream.proto package pbpeerstream import ( "github.com/golang/protobuf/proto" ) // MarshalBinary implements encoding.BinaryMarshaler func (msg *ReplicationMessage) MarshalBinary() ([]byte, error) { return proto.Marshal(msg) } // UnmarshalBinary implements encoding.BinaryUnmarshaler func (msg *ReplicationMessage) UnmarshalBinary(b []byte) error { return proto.Unmarshal(b, msg) } // MarshalBinary implements encoding.BinaryMarshaler func (msg *ReplicationMessage_Request) MarshalBinary() ([]byte, error) { return proto.Marshal(msg) } // UnmarshalBinary implements encoding.BinaryUnmarshaler func (msg *ReplicationMessage_Request) UnmarshalBinary(b []byte) error { return proto.Unmarshal(b, msg) } // MarshalBinary implements encoding.BinaryMarshaler func (msg *ReplicationMessage_Response) MarshalBinary() ([]byte, error) { return proto.Marshal(msg) } // UnmarshalBinary implements encoding.BinaryUnmarshaler func (msg *ReplicationMessage_Response) UnmarshalBinary(b []byte) error { return proto.Unmarshal(b, msg) } // MarshalBinary implements encoding.BinaryMarshaler func (msg *ReplicationMessage_Terminated) MarshalBinary() ([]byte, error) { return proto.Marshal(msg) } // UnmarshalBinary implements encoding.BinaryUnmarshaler func (msg *ReplicationMessage_Terminated) UnmarshalBinary(b []byte) error { return proto.Unmarshal(b, msg) } // MarshalBinary implements encoding.BinaryMarshaler func (msg *LeaderAddress) MarshalBinary() ([]byte, error) { return proto.Marshal(msg) } // UnmarshalBinary implements encoding.BinaryUnmarshaler func (msg *LeaderAddress) UnmarshalBinary(b []byte) error { return proto.Unmarshal(b, msg) } // MarshalBinary implements encoding.BinaryMarshaler func (msg *ExportedService) MarshalBinary() ([]byte, error) { return proto.Marshal(msg) } // UnmarshalBinary implements encoding.BinaryUnmarshaler func (msg *ExportedService) UnmarshalBinary(b []byte) error { return proto.Unmarshal(b, msg) }