gravity_api_dsa

type DataSourceAdapterClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishReply, error)
	PublishEvents(ctx context.Context, opts ...grpc.CallOption) (DataSourceAdapter_PublishEventsClient, error)
}

type DataSourceAdapterServer interface {
	Publish(context.Context, *PublishRequest) (*PublishReply, error)
	PublishEvents(DataSourceAdapter_PublishEventsServer) error
}

type DataSourceAdapter_PublishEventsClient interface {
	Send(*PublishRequest) error
	CloseAndRecv() (*PublishReply, error)
	grpc.ClientStream
}

type DataSourceAdapter_PublishEventsServer interface {
	SendAndClose(*PublishReply) error
	Recv() (*PublishRequest, error)
	grpc.ServerStream
}

type PublishReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type PublishRequest struct {
	EventName            string   `protobuf:"bytes,1,opt,name=eventName,proto3" json:"eventName,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type UnimplementedDataSourceAdapterServer struct {
}