proto

type CatalogClient interface {
	Registry(ctx context.Context, in *RegistryRequest, opts ...grpc.CallOption) (*RegistryResponse, error)
	QueryOperations(ctx context.Context, in *QueryOperationsRequest, opts ...grpc.CallOption) (*QueryOperationsResponse, error)
}

type CatalogServer interface {
	Registry(context.Context, *RegistryRequest) (*RegistryResponse, error)
	QueryOperations(context.Context, *QueryOperationsRequest) (*QueryOperationsResponse, error)
	// contains filtered or unexported methods
}

type Operation struct {
	ChannelName string `protobuf:"bytes,1,opt,name=channel_name,json=channelName,proto3" json:"channel_name,omitempty"`
	Schema      string `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// publish/subscribe
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type QueryOperationsRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

type QueryOperationsResponse struct {
	Operations []*Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

type RegistryRequest struct {
	FileName   string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Definition string `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

type RegistryResponse struct {
	// contains filtered or unexported fields
}

type UnimplementedCatalogServer struct {
}

type UnsafeCatalogServer interface {
	// contains filtered or unexported methods
}