destination

func (*Server) Close ¶

func (s *Server) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)

func (*Server) Configure ¶

func (s *Server) Configure(ctx context.Context, req *pbBase.Configure_Request) (*pbBase.Configure_Response, error)

func (*Server) DeleteStale ¶

func (s *Server) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)

func (*Server) GetMetrics ¶

func (s *Server) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)

func (*Server) GetName ¶

func (s *Server) GetName(context.Context, *pbBase.GetName_Request) (*pbBase.GetName_Response, error)

func (*Server) GetProtocolVersion ¶

func (*Server) GetProtocolVersion(context.Context, *pbBase.GetProtocolVersion_Request) (*pbBase.GetProtocolVersion_Response, error)

func (*Server) GetVersion ¶

func (s *Server) GetVersion(context.Context, *pbBase.GetVersion_Request) (*pbBase.GetVersion_Response, error)

func (*Server) Migrate ¶

func (s *Server) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)

func (*Server) Write ¶

func (*Server) Write(pb.Destination_WriteServer) error

func (*Server) Write2 ¶

func (s *Server) Write2(msg pb.Destination_Write2Server) error

Note the order of operations in this method is important! Trying to insert into the `resources` channel before starting the reader goroutine will cause a deadlock.