Documentation ¶
Overview ¶
Package crudstore is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- func RegisterCrudStoreServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterCrudStoreServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CrudStoreServiceClient) error
- func RegisterCrudStoreServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterCrudStoreServiceServer(s *grpc.Server, srv CrudStoreServiceServer)
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetEntityType() string
- func (m *CreateRequest) GetOriginator() *common.Originator
- func (m *CreateRequest) GetPayload() string
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) String() string
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetOriginator() *common.Originator
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) String() string
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type CrudEntitySpec
- func (*CrudEntitySpec) Descriptor() ([]byte, []int)
- func (m *CrudEntitySpec) GetEntityType() string
- func (m *CrudEntitySpec) GetSchemaSpec() *SchemaSpec
- func (*CrudEntitySpec) ProtoMessage()
- func (m *CrudEntitySpec) Reset()
- func (m *CrudEntitySpec) String() string
- func (m *CrudEntitySpec) XXX_DiscardUnknown()
- func (m *CrudEntitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CrudEntitySpec) XXX_Merge(src proto.Message)
- func (m *CrudEntitySpec) XXX_Size() int
- func (m *CrudEntitySpec) XXX_Unmarshal(b []byte) error
- type CrudStoreServiceClient
- type CrudStoreServiceServer
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetEntityType() string
- func (m *DeleteRequest) GetOriginator() *common.Originator
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) XXX_DiscardUnknown()
- func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRequest) XXX_Size() int
- func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) GetOriginator() *common.Originator
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) XXX_DiscardUnknown()
- func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteResponse) XXX_Merge(src proto.Message)
- func (m *DeleteResponse) XXX_Size() int
- func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetDeleted() bool
- func (m *GetRequest) GetEntityType() string
- func (m *GetRequest) GetOriginator() *common.Originator
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) String() string
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetOriginator() *common.Originator
- func (m *GetResponse) GetPayload() string
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) String() string
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type GetTypeRequest
- func (*GetTypeRequest) Descriptor() ([]byte, []int)
- func (m *GetTypeRequest) GetEntityType() string
- func (*GetTypeRequest) ProtoMessage()
- func (m *GetTypeRequest) Reset()
- func (m *GetTypeRequest) String() string
- func (m *GetTypeRequest) XXX_DiscardUnknown()
- func (m *GetTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTypeRequest) XXX_Merge(src proto.Message)
- func (m *GetTypeRequest) XXX_Size() int
- func (m *GetTypeRequest) XXX_Unmarshal(b []byte) error
- type GetTypeResponse
- func (*GetTypeResponse) Descriptor() ([]byte, []int)
- func (m *GetTypeResponse) GetSpec() *CrudEntitySpec
- func (*GetTypeResponse) ProtoMessage()
- func (m *GetTypeResponse) Reset()
- func (m *GetTypeResponse) String() string
- func (m *GetTypeResponse) XXX_DiscardUnknown()
- func (m *GetTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTypeResponse) XXX_Merge(src proto.Message)
- func (m *GetTypeResponse) XXX_Size() int
- func (m *GetTypeResponse) XXX_Unmarshal(b []byte) error
- type HealthRequest
- func (*HealthRequest) Descriptor() ([]byte, []int)
- func (*HealthRequest) ProtoMessage()
- func (m *HealthRequest) Reset()
- func (m *HealthRequest) String() string
- func (m *HealthRequest) XXX_DiscardUnknown()
- func (m *HealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthRequest) XXX_Merge(src proto.Message)
- func (m *HealthRequest) XXX_Size() int
- func (m *HealthRequest) XXX_Unmarshal(b []byte) error
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthResponse) GetMessage() string
- func (*HealthResponse) ProtoMessage()
- func (m *HealthResponse) Reset()
- func (m *HealthResponse) String() string
- func (m *HealthResponse) XXX_DiscardUnknown()
- func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthResponse) XXX_Merge(src proto.Message)
- func (m *HealthResponse) XXX_Size() int
- func (m *HealthResponse) XXX_Unmarshal(b []byte) error
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetEntityType() string
- func (m *ListRequest) GetLimit() uint32
- func (m *ListRequest) GetPaginationId() string
- func (m *ListRequest) GetSkipPayload() bool
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) String() string
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)
- func (m *ListResponse) GetNextPageId() string
- func (m *ListResponse) GetResults() []*ListResponseItem
- func (*ListResponse) ProtoMessage()
- func (m *ListResponse) Reset()
- func (m *ListResponse) String() string
- func (m *ListResponse) XXX_DiscardUnknown()
- func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListResponse) XXX_Merge(src proto.Message)
- func (m *ListResponse) XXX_Size() int
- func (m *ListResponse) XXX_Unmarshal(b []byte) error
- type ListResponseItem
- func (*ListResponseItem) Descriptor() ([]byte, []int)
- func (m *ListResponseItem) GetEntityType() string
- func (m *ListResponseItem) GetOriginator() *common.Originator
- func (m *ListResponseItem) GetPayload() string
- func (*ListResponseItem) ProtoMessage()
- func (m *ListResponseItem) Reset()
- func (m *ListResponseItem) String() string
- func (m *ListResponseItem) XXX_DiscardUnknown()
- func (m *ListResponseItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListResponseItem) XXX_Merge(src proto.Message)
- func (m *ListResponseItem) XXX_Size() int
- func (m *ListResponseItem) XXX_Unmarshal(b []byte) error
- type ListTypesRequest
- func (*ListTypesRequest) Descriptor() ([]byte, []int)
- func (m *ListTypesRequest) GetLimit() uint32
- func (*ListTypesRequest) ProtoMessage()
- func (m *ListTypesRequest) Reset()
- func (m *ListTypesRequest) String() string
- func (m *ListTypesRequest) XXX_DiscardUnknown()
- func (m *ListTypesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTypesRequest) XXX_Merge(src proto.Message)
- func (m *ListTypesRequest) XXX_Size() int
- func (m *ListTypesRequest) XXX_Unmarshal(b []byte) error
- type ListTypesResponse
- func (*ListTypesResponse) Descriptor() ([]byte, []int)
- func (m *ListTypesResponse) GetResults() []*CrudEntitySpec
- func (*ListTypesResponse) ProtoMessage()
- func (m *ListTypesResponse) Reset()
- func (m *ListTypesResponse) String() string
- func (m *ListTypesResponse) XXX_DiscardUnknown()
- func (m *ListTypesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListTypesResponse) XXX_Merge(src proto.Message)
- func (m *ListTypesResponse) XXX_Size() int
- func (m *ListTypesResponse) XXX_Unmarshal(b []byte) error
- type RegisterTypeRequest
- func (*RegisterTypeRequest) Descriptor() ([]byte, []int)
- func (m *RegisterTypeRequest) GetSkipDuplicate() bool
- func (m *RegisterTypeRequest) GetSpec() *CrudEntitySpec
- func (*RegisterTypeRequest) ProtoMessage()
- func (m *RegisterTypeRequest) Reset()
- func (m *RegisterTypeRequest) String() string
- func (m *RegisterTypeRequest) XXX_DiscardUnknown()
- func (m *RegisterTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterTypeRequest) XXX_Merge(src proto.Message)
- func (m *RegisterTypeRequest) XXX_Size() int
- func (m *RegisterTypeRequest) XXX_Unmarshal(b []byte) error
- type RegisterTypeResponse
- func (*RegisterTypeResponse) Descriptor() ([]byte, []int)
- func (*RegisterTypeResponse) ProtoMessage()
- func (m *RegisterTypeResponse) Reset()
- func (m *RegisterTypeResponse) String() string
- func (m *RegisterTypeResponse) XXX_DiscardUnknown()
- func (m *RegisterTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterTypeResponse) XXX_Merge(src proto.Message)
- func (m *RegisterTypeResponse) XXX_Size() int
- func (m *RegisterTypeResponse) XXX_Unmarshal(b []byte) error
- type SchemaSpec
- func (*SchemaSpec) Descriptor() ([]byte, []int)
- func (m *SchemaSpec) GetJsonSchema() string
- func (m *SchemaSpec) GetSchemaVersion() uint64
- func (*SchemaSpec) ProtoMessage()
- func (m *SchemaSpec) Reset()
- func (m *SchemaSpec) String() string
- func (m *SchemaSpec) XXX_DiscardUnknown()
- func (m *SchemaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SchemaSpec) XXX_Merge(src proto.Message)
- func (m *SchemaSpec) XXX_Size() int
- func (m *SchemaSpec) XXX_Unmarshal(b []byte) error
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRequest) GetEntityType() string
- func (m *UpdateRequest) GetOriginator() *common.Originator
- func (m *UpdateRequest) GetPayload() string
- func (*UpdateRequest) ProtoMessage()
- func (m *UpdateRequest) Reset()
- func (m *UpdateRequest) String() string
- func (m *UpdateRequest) XXX_DiscardUnknown()
- func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRequest) XXX_Size() int
- func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
- type UpdateResponse
- func (*UpdateResponse) Descriptor() ([]byte, []int)
- func (m *UpdateResponse) GetOriginator() *common.Originator
- func (*UpdateResponse) ProtoMessage()
- func (m *UpdateResponse) Reset()
- func (m *UpdateResponse) String() string
- func (m *UpdateResponse) XXX_DiscardUnknown()
- func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateResponse) XXX_Merge(src proto.Message)
- func (m *UpdateResponse) XXX_Size() int
- func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
- type UpdateTypeRequest
- func (*UpdateTypeRequest) Descriptor() ([]byte, []int)
- func (m *UpdateTypeRequest) GetSpec() *CrudEntitySpec
- func (*UpdateTypeRequest) ProtoMessage()
- func (m *UpdateTypeRequest) Reset()
- func (m *UpdateTypeRequest) String() string
- func (m *UpdateTypeRequest) XXX_DiscardUnknown()
- func (m *UpdateTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateTypeRequest) XXX_Merge(src proto.Message)
- func (m *UpdateTypeRequest) XXX_Size() int
- func (m *UpdateTypeRequest) XXX_Unmarshal(b []byte) error
- type UpdateTypeResponse
- func (*UpdateTypeResponse) Descriptor() ([]byte, []int)
- func (*UpdateTypeResponse) ProtoMessage()
- func (m *UpdateTypeResponse) Reset()
- func (m *UpdateTypeResponse) String() string
- func (m *UpdateTypeResponse) XXX_DiscardUnknown()
- func (m *UpdateTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateTypeResponse) XXX_Merge(src proto.Message)
- func (m *UpdateTypeResponse) XXX_Size() int
- func (m *UpdateTypeResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCrudStoreServiceHandler ¶
func RegisterCrudStoreServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterCrudStoreServiceHandler registers the http handlers for service CrudStoreService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterCrudStoreServiceHandlerClient ¶
func RegisterCrudStoreServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client CrudStoreServiceClient) error
RegisterCrudStoreServiceHandlerClient registers the http handlers for service CrudStoreService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "CrudStoreServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "CrudStoreServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "CrudStoreServiceClient" to call the correct interceptors.
func RegisterCrudStoreServiceHandlerFromEndpoint ¶
func RegisterCrudStoreServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterCrudStoreServiceHandlerFromEndpoint is same as RegisterCrudStoreServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterCrudStoreServiceServer ¶
func RegisterCrudStoreServiceServer(s *grpc.Server, srv CrudStoreServiceServer)
Types ¶
type CreateRequest ¶
type CreateRequest struct { // entity type of the object, could be User, Project and etc EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` // originator of the object, if not supplied it'll be auto generated Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"` // payload is a json valid string that has the body of the object Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetEntityType ¶
func (m *CreateRequest) GetEntityType() string
func (*CreateRequest) GetOriginator ¶
func (m *CreateRequest) GetOriginator() *common.Originator
func (*CreateRequest) GetPayload ¶
func (m *CreateRequest) GetPayload() string
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct { Originator *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetOriginator ¶
func (m *CreateResponse) GetOriginator() *common.Originator
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type CrudEntitySpec ¶
type CrudEntitySpec struct { // the entity type we're registering like Project, User and etc // if have same entity on different bounded contexes can use packages // like com.makkalot.User, this field is required EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` SchemaSpec *SchemaSpec `protobuf:"bytes,2,opt,name=schema_spec,json=schemaSpec,proto3" json:"schema_spec,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CrudEntitySpec) Descriptor ¶
func (*CrudEntitySpec) Descriptor() ([]byte, []int)
func (*CrudEntitySpec) GetEntityType ¶
func (m *CrudEntitySpec) GetEntityType() string
func (*CrudEntitySpec) GetSchemaSpec ¶
func (m *CrudEntitySpec) GetSchemaSpec() *SchemaSpec
func (*CrudEntitySpec) ProtoMessage ¶
func (*CrudEntitySpec) ProtoMessage()
func (*CrudEntitySpec) Reset ¶
func (m *CrudEntitySpec) Reset()
func (*CrudEntitySpec) String ¶
func (m *CrudEntitySpec) String() string
func (*CrudEntitySpec) XXX_DiscardUnknown ¶
func (m *CrudEntitySpec) XXX_DiscardUnknown()
func (*CrudEntitySpec) XXX_Marshal ¶
func (m *CrudEntitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CrudEntitySpec) XXX_Merge ¶
func (m *CrudEntitySpec) XXX_Merge(src proto.Message)
func (*CrudEntitySpec) XXX_Size ¶
func (m *CrudEntitySpec) XXX_Size() int
func (*CrudEntitySpec) XXX_Unmarshal ¶
func (m *CrudEntitySpec) XXX_Unmarshal(b []byte) error
type CrudStoreServiceClient ¶
type CrudStoreServiceClient interface { Healtz(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) // List endpoint is a debug endpoint and could be very slow // for objects with lots of events, if want faster list access // use a proper read model and create a different service endpoint for it // also note that it can return duplicate results as well for different pages List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) RegisterType(ctx context.Context, in *RegisterTypeRequest, opts ...grpc.CallOption) (*RegisterTypeResponse, error) // The request is eventually consistent GetType(ctx context.Context, in *GetTypeRequest, opts ...grpc.CallOption) (*GetTypeResponse, error) // updates the type and the schema UpdateType(ctx context.Context, in *UpdateTypeRequest, opts ...grpc.CallOption) (*UpdateTypeResponse, error) // it's for debugging purposes might be a bit slow, for better results // use a different index ListTypes(ctx context.Context, in *ListTypesRequest, opts ...grpc.CallOption) (*ListTypesResponse, error) }
CrudStoreServiceClient is the client API for CrudStoreService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCrudStoreServiceClient ¶
func NewCrudStoreServiceClient(cc *grpc.ClientConn) CrudStoreServiceClient
type CrudStoreServiceServer ¶
type CrudStoreServiceServer interface { Healtz(context.Context, *HealthRequest) (*HealthResponse, error) Create(context.Context, *CreateRequest) (*CreateResponse, error) Update(context.Context, *UpdateRequest) (*UpdateResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) // List endpoint is a debug endpoint and could be very slow // for objects with lots of events, if want faster list access // use a proper read model and create a different service endpoint for it // also note that it can return duplicate results as well for different pages List(context.Context, *ListRequest) (*ListResponse, error) RegisterType(context.Context, *RegisterTypeRequest) (*RegisterTypeResponse, error) // The request is eventually consistent GetType(context.Context, *GetTypeRequest) (*GetTypeResponse, error) // updates the type and the schema UpdateType(context.Context, *UpdateTypeRequest) (*UpdateTypeResponse, error) // it's for debugging purposes might be a bit slow, for better results // use a different index ListTypes(context.Context, *ListTypesRequest) (*ListTypesResponse, error) }
CrudStoreServiceServer is the server API for CrudStoreService service.
type DeleteRequest ¶
type DeleteRequest struct { EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` // originator is the id of the object Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetEntityType ¶
func (m *DeleteRequest) GetEntityType() string
func (*DeleteRequest) GetOriginator ¶
func (m *DeleteRequest) GetOriginator() *common.Originator
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) XXX_DiscardUnknown ¶
func (m *DeleteRequest) XXX_DiscardUnknown()
func (*DeleteRequest) XXX_Marshal ¶
func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRequest) XXX_Merge ¶
func (m *DeleteRequest) XXX_Merge(src proto.Message)
func (*DeleteRequest) XXX_Size ¶
func (m *DeleteRequest) XXX_Size() int
func (*DeleteRequest) XXX_Unmarshal ¶
func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
type DeleteResponse ¶
type DeleteResponse struct { // originator is the id of the object Originator *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) GetOriginator ¶
func (m *DeleteResponse) GetOriginator() *common.Originator
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) XXX_DiscardUnknown ¶
func (m *DeleteResponse) XXX_DiscardUnknown()
func (*DeleteResponse) XXX_Marshal ¶
func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteResponse) XXX_Merge ¶
func (m *DeleteResponse) XXX_Merge(src proto.Message)
func (*DeleteResponse) XXX_Size ¶
func (m *DeleteResponse) XXX_Size() int
func (*DeleteResponse) XXX_Unmarshal ¶
func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct { // something like User, Project and etc EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` // originator is the id of the object Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"` // fetch deleted Deleted bool `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetDeleted ¶
func (m *GetRequest) GetDeleted() bool
func (*GetRequest) GetEntityType ¶
func (m *GetRequest) GetEntityType() string
func (*GetRequest) GetOriginator ¶
func (m *GetRequest) GetOriginator() *common.Originator
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct { Originator *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"` // json representation of the body Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetOriginator ¶
func (m *GetResponse) GetOriginator() *common.Originator
func (*GetResponse) GetPayload ¶
func (m *GetResponse) GetPayload() string
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type GetTypeRequest ¶
type GetTypeRequest struct { EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTypeRequest) Descriptor ¶
func (*GetTypeRequest) Descriptor() ([]byte, []int)
func (*GetTypeRequest) GetEntityType ¶
func (m *GetTypeRequest) GetEntityType() string
func (*GetTypeRequest) ProtoMessage ¶
func (*GetTypeRequest) ProtoMessage()
func (*GetTypeRequest) Reset ¶
func (m *GetTypeRequest) Reset()
func (*GetTypeRequest) String ¶
func (m *GetTypeRequest) String() string
func (*GetTypeRequest) XXX_DiscardUnknown ¶
func (m *GetTypeRequest) XXX_DiscardUnknown()
func (*GetTypeRequest) XXX_Marshal ¶
func (m *GetTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTypeRequest) XXX_Merge ¶
func (m *GetTypeRequest) XXX_Merge(src proto.Message)
func (*GetTypeRequest) XXX_Size ¶
func (m *GetTypeRequest) XXX_Size() int
func (*GetTypeRequest) XXX_Unmarshal ¶
func (m *GetTypeRequest) XXX_Unmarshal(b []byte) error
type GetTypeResponse ¶
type GetTypeResponse struct { Spec *CrudEntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTypeResponse) Descriptor ¶
func (*GetTypeResponse) Descriptor() ([]byte, []int)
func (*GetTypeResponse) GetSpec ¶
func (m *GetTypeResponse) GetSpec() *CrudEntitySpec
func (*GetTypeResponse) ProtoMessage ¶
func (*GetTypeResponse) ProtoMessage()
func (*GetTypeResponse) Reset ¶
func (m *GetTypeResponse) Reset()
func (*GetTypeResponse) String ¶
func (m *GetTypeResponse) String() string
func (*GetTypeResponse) XXX_DiscardUnknown ¶
func (m *GetTypeResponse) XXX_DiscardUnknown()
func (*GetTypeResponse) XXX_Marshal ¶
func (m *GetTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTypeResponse) XXX_Merge ¶
func (m *GetTypeResponse) XXX_Merge(src proto.Message)
func (*GetTypeResponse) XXX_Size ¶
func (m *GetTypeResponse) XXX_Size() int
func (*GetTypeResponse) XXX_Unmarshal ¶
func (m *GetTypeResponse) XXX_Unmarshal(b []byte) error
type HealthRequest ¶
type HealthRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthRequest) Descriptor ¶
func (*HealthRequest) Descriptor() ([]byte, []int)
func (*HealthRequest) ProtoMessage ¶
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) Reset ¶
func (m *HealthRequest) Reset()
func (*HealthRequest) String ¶
func (m *HealthRequest) String() string
func (*HealthRequest) XXX_DiscardUnknown ¶
func (m *HealthRequest) XXX_DiscardUnknown()
func (*HealthRequest) XXX_Marshal ¶
func (m *HealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthRequest) XXX_Merge ¶
func (m *HealthRequest) XXX_Merge(src proto.Message)
func (*HealthRequest) XXX_Size ¶
func (m *HealthRequest) XXX_Size() int
func (*HealthRequest) XXX_Unmarshal ¶
func (m *HealthRequest) XXX_Unmarshal(b []byte) error
type HealthResponse ¶
type HealthResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthResponse) Descriptor ¶
func (*HealthResponse) Descriptor() ([]byte, []int)
func (*HealthResponse) GetMessage ¶
func (m *HealthResponse) GetMessage() string
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) Reset ¶
func (m *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (m *HealthResponse) String() string
func (*HealthResponse) XXX_DiscardUnknown ¶
func (m *HealthResponse) XXX_DiscardUnknown()
func (*HealthResponse) XXX_Marshal ¶
func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthResponse) XXX_Merge ¶
func (m *HealthResponse) XXX_Merge(src proto.Message)
func (*HealthResponse) XXX_Size ¶
func (m *HealthResponse) XXX_Size() int
func (*HealthResponse) XXX_Unmarshal ¶
func (m *HealthResponse) XXX_Unmarshal(b []byte) error
type ListRequest ¶
type ListRequest struct { // entity type is required parameter EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` // pagination id is optional if not supplied starts scanning from the beginning PaginationId string `protobuf:"bytes,2,opt,name=pagination_id,json=paginationId,proto3" json:"pagination_id,omitempty"` // optional, if not supplied it's 10 Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` SkipPayload bool `protobuf:"varint,4,opt,name=skip_payload,json=skipPayload,proto3" json:"skip_payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetEntityType ¶
func (m *ListRequest) GetEntityType() string
func (*ListRequest) GetLimit ¶
func (m *ListRequest) GetLimit() uint32
func (*ListRequest) GetPaginationId ¶
func (m *ListRequest) GetPaginationId() string
func (*ListRequest) GetSkipPayload ¶
func (m *ListRequest) GetSkipPayload() bool
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) XXX_DiscardUnknown ¶
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type ListResponse ¶
type ListResponse struct { Results []*ListResponseItem `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` NextPageId string `protobuf:"bytes,2,opt,name=next_page_id,json=nextPageId,proto3" json:"next_page_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListResponse) Descriptor ¶
func (*ListResponse) Descriptor() ([]byte, []int)
func (*ListResponse) GetNextPageId ¶
func (m *ListResponse) GetNextPageId() string
func (*ListResponse) GetResults ¶
func (m *ListResponse) GetResults() []*ListResponseItem
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) Reset ¶
func (m *ListResponse) Reset()
func (*ListResponse) String ¶
func (m *ListResponse) String() string
func (*ListResponse) XXX_DiscardUnknown ¶
func (m *ListResponse) XXX_DiscardUnknown()
func (*ListResponse) XXX_Marshal ¶
func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListResponse) XXX_Merge ¶
func (m *ListResponse) XXX_Merge(src proto.Message)
func (*ListResponse) XXX_Size ¶
func (m *ListResponse) XXX_Size() int
func (*ListResponse) XXX_Unmarshal ¶
func (m *ListResponse) XXX_Unmarshal(b []byte) error
type ListResponseItem ¶
type ListResponseItem struct { EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"` Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListResponseItem) Descriptor ¶
func (*ListResponseItem) Descriptor() ([]byte, []int)
func (*ListResponseItem) GetEntityType ¶
func (m *ListResponseItem) GetEntityType() string
func (*ListResponseItem) GetOriginator ¶
func (m *ListResponseItem) GetOriginator() *common.Originator
func (*ListResponseItem) GetPayload ¶
func (m *ListResponseItem) GetPayload() string
func (*ListResponseItem) ProtoMessage ¶
func (*ListResponseItem) ProtoMessage()
func (*ListResponseItem) Reset ¶
func (m *ListResponseItem) Reset()
func (*ListResponseItem) String ¶
func (m *ListResponseItem) String() string
func (*ListResponseItem) XXX_DiscardUnknown ¶
func (m *ListResponseItem) XXX_DiscardUnknown()
func (*ListResponseItem) XXX_Marshal ¶
func (m *ListResponseItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListResponseItem) XXX_Merge ¶
func (m *ListResponseItem) XXX_Merge(src proto.Message)
func (*ListResponseItem) XXX_Size ¶
func (m *ListResponseItem) XXX_Size() int
func (*ListResponseItem) XXX_Unmarshal ¶
func (m *ListResponseItem) XXX_Unmarshal(b []byte) error
type ListTypesRequest ¶
type ListTypesRequest struct { // optional, if not supplied it's 20 Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListTypesRequest) Descriptor ¶
func (*ListTypesRequest) Descriptor() ([]byte, []int)
func (*ListTypesRequest) GetLimit ¶
func (m *ListTypesRequest) GetLimit() uint32
func (*ListTypesRequest) ProtoMessage ¶
func (*ListTypesRequest) ProtoMessage()
func (*ListTypesRequest) Reset ¶
func (m *ListTypesRequest) Reset()
func (*ListTypesRequest) String ¶
func (m *ListTypesRequest) String() string
func (*ListTypesRequest) XXX_DiscardUnknown ¶
func (m *ListTypesRequest) XXX_DiscardUnknown()
func (*ListTypesRequest) XXX_Marshal ¶
func (m *ListTypesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTypesRequest) XXX_Merge ¶
func (m *ListTypesRequest) XXX_Merge(src proto.Message)
func (*ListTypesRequest) XXX_Size ¶
func (m *ListTypesRequest) XXX_Size() int
func (*ListTypesRequest) XXX_Unmarshal ¶
func (m *ListTypesRequest) XXX_Unmarshal(b []byte) error
type ListTypesResponse ¶
type ListTypesResponse struct { Results []*CrudEntitySpec `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListTypesResponse) Descriptor ¶
func (*ListTypesResponse) Descriptor() ([]byte, []int)
func (*ListTypesResponse) GetResults ¶
func (m *ListTypesResponse) GetResults() []*CrudEntitySpec
func (*ListTypesResponse) ProtoMessage ¶
func (*ListTypesResponse) ProtoMessage()
func (*ListTypesResponse) Reset ¶
func (m *ListTypesResponse) Reset()
func (*ListTypesResponse) String ¶
func (m *ListTypesResponse) String() string
func (*ListTypesResponse) XXX_DiscardUnknown ¶
func (m *ListTypesResponse) XXX_DiscardUnknown()
func (*ListTypesResponse) XXX_Marshal ¶
func (m *ListTypesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTypesResponse) XXX_Merge ¶
func (m *ListTypesResponse) XXX_Merge(src proto.Message)
func (*ListTypesResponse) XXX_Size ¶
func (m *ListTypesResponse) XXX_Size() int
func (*ListTypesResponse) XXX_Unmarshal ¶
func (m *ListTypesResponse) XXX_Unmarshal(b []byte) error
type RegisterTypeRequest ¶
type RegisterTypeRequest struct { Spec *CrudEntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // if the record already exists it doesn't error SkipDuplicate bool `protobuf:"varint,2,opt,name=skip_duplicate,json=skipDuplicate,proto3" json:"skip_duplicate,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterTypeRequest) Descriptor ¶
func (*RegisterTypeRequest) Descriptor() ([]byte, []int)
func (*RegisterTypeRequest) GetSkipDuplicate ¶
func (m *RegisterTypeRequest) GetSkipDuplicate() bool
func (*RegisterTypeRequest) GetSpec ¶
func (m *RegisterTypeRequest) GetSpec() *CrudEntitySpec
func (*RegisterTypeRequest) ProtoMessage ¶
func (*RegisterTypeRequest) ProtoMessage()
func (*RegisterTypeRequest) Reset ¶
func (m *RegisterTypeRequest) Reset()
func (*RegisterTypeRequest) String ¶
func (m *RegisterTypeRequest) String() string
func (*RegisterTypeRequest) XXX_DiscardUnknown ¶
func (m *RegisterTypeRequest) XXX_DiscardUnknown()
func (*RegisterTypeRequest) XXX_Marshal ¶
func (m *RegisterTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterTypeRequest) XXX_Merge ¶
func (m *RegisterTypeRequest) XXX_Merge(src proto.Message)
func (*RegisterTypeRequest) XXX_Size ¶
func (m *RegisterTypeRequest) XXX_Size() int
func (*RegisterTypeRequest) XXX_Unmarshal ¶
func (m *RegisterTypeRequest) XXX_Unmarshal(b []byte) error
type RegisterTypeResponse ¶
type RegisterTypeResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegisterTypeResponse) Descriptor ¶
func (*RegisterTypeResponse) Descriptor() ([]byte, []int)
func (*RegisterTypeResponse) ProtoMessage ¶
func (*RegisterTypeResponse) ProtoMessage()
func (*RegisterTypeResponse) Reset ¶
func (m *RegisterTypeResponse) Reset()
func (*RegisterTypeResponse) String ¶
func (m *RegisterTypeResponse) String() string
func (*RegisterTypeResponse) XXX_DiscardUnknown ¶
func (m *RegisterTypeResponse) XXX_DiscardUnknown()
func (*RegisterTypeResponse) XXX_Marshal ¶
func (m *RegisterTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterTypeResponse) XXX_Merge ¶
func (m *RegisterTypeResponse) XXX_Merge(src proto.Message)
func (*RegisterTypeResponse) XXX_Size ¶
func (m *RegisterTypeResponse) XXX_Size() int
func (*RegisterTypeResponse) XXX_Unmarshal ¶
func (m *RegisterTypeResponse) XXX_Unmarshal(b []byte) error
type SchemaSpec ¶
type SchemaSpec struct { // optional field that keeps the version of the schema for that object // field can be used to make sure the client are sending objects against // the latest version of the schema registered in the system SchemaVersion uint64 `protobuf:"varint,1,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // optional field that is used for validating the entity for certain // schema version. If empty no validation is done, if supplied the submitted // object is validated against the schema JsonSchema string `protobuf:"bytes,2,opt,name=json_schema,json=jsonSchema,proto3" json:"json_schema,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SchemaSpec) Descriptor ¶
func (*SchemaSpec) Descriptor() ([]byte, []int)
func (*SchemaSpec) GetJsonSchema ¶
func (m *SchemaSpec) GetJsonSchema() string
func (*SchemaSpec) GetSchemaVersion ¶
func (m *SchemaSpec) GetSchemaVersion() uint64
func (*SchemaSpec) ProtoMessage ¶
func (*SchemaSpec) ProtoMessage()
func (*SchemaSpec) Reset ¶
func (m *SchemaSpec) Reset()
func (*SchemaSpec) String ¶
func (m *SchemaSpec) String() string
func (*SchemaSpec) XXX_DiscardUnknown ¶
func (m *SchemaSpec) XXX_DiscardUnknown()
func (*SchemaSpec) XXX_Marshal ¶
func (m *SchemaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SchemaSpec) XXX_Merge ¶
func (m *SchemaSpec) XXX_Merge(src proto.Message)
func (*SchemaSpec) XXX_Size ¶
func (m *SchemaSpec) XXX_Size() int
func (*SchemaSpec) XXX_Unmarshal ¶
func (m *SchemaSpec) XXX_Unmarshal(b []byte) error
type UpdateRequest ¶
type UpdateRequest struct { // entity type of the object, could be User, Project and etc EntityType string `protobuf:"bytes,1,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` // originator of the object Originator *common.Originator `protobuf:"bytes,2,opt,name=originator,proto3" json:"originator,omitempty"` // payload is a json valid string that has the body of the object Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateRequest) Descriptor ¶
func (*UpdateRequest) Descriptor() ([]byte, []int)
func (*UpdateRequest) GetEntityType ¶
func (m *UpdateRequest) GetEntityType() string
func (*UpdateRequest) GetOriginator ¶
func (m *UpdateRequest) GetOriginator() *common.Originator
func (*UpdateRequest) GetPayload ¶
func (m *UpdateRequest) GetPayload() string
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) Reset ¶
func (m *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (m *UpdateRequest) String() string
func (*UpdateRequest) XXX_DiscardUnknown ¶
func (m *UpdateRequest) XXX_DiscardUnknown()
func (*UpdateRequest) XXX_Marshal ¶
func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRequest) XXX_Merge ¶
func (m *UpdateRequest) XXX_Merge(src proto.Message)
func (*UpdateRequest) XXX_Size ¶
func (m *UpdateRequest) XXX_Size() int
func (*UpdateRequest) XXX_Unmarshal ¶
func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
type UpdateResponse ¶
type UpdateResponse struct { Originator *common.Originator `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateResponse) Descriptor ¶
func (*UpdateResponse) Descriptor() ([]byte, []int)
func (*UpdateResponse) GetOriginator ¶
func (m *UpdateResponse) GetOriginator() *common.Originator
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) Reset ¶
func (m *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (m *UpdateResponse) String() string
func (*UpdateResponse) XXX_DiscardUnknown ¶
func (m *UpdateResponse) XXX_DiscardUnknown()
func (*UpdateResponse) XXX_Marshal ¶
func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateResponse) XXX_Merge ¶
func (m *UpdateResponse) XXX_Merge(src proto.Message)
func (*UpdateResponse) XXX_Size ¶
func (m *UpdateResponse) XXX_Size() int
func (*UpdateResponse) XXX_Unmarshal ¶
func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
type UpdateTypeRequest ¶
type UpdateTypeRequest struct { Spec *CrudEntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateTypeRequest) Descriptor ¶
func (*UpdateTypeRequest) Descriptor() ([]byte, []int)
func (*UpdateTypeRequest) GetSpec ¶
func (m *UpdateTypeRequest) GetSpec() *CrudEntitySpec
func (*UpdateTypeRequest) ProtoMessage ¶
func (*UpdateTypeRequest) ProtoMessage()
func (*UpdateTypeRequest) Reset ¶
func (m *UpdateTypeRequest) Reset()
func (*UpdateTypeRequest) String ¶
func (m *UpdateTypeRequest) String() string
func (*UpdateTypeRequest) XXX_DiscardUnknown ¶
func (m *UpdateTypeRequest) XXX_DiscardUnknown()
func (*UpdateTypeRequest) XXX_Marshal ¶
func (m *UpdateTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateTypeRequest) XXX_Merge ¶
func (m *UpdateTypeRequest) XXX_Merge(src proto.Message)
func (*UpdateTypeRequest) XXX_Size ¶
func (m *UpdateTypeRequest) XXX_Size() int
func (*UpdateTypeRequest) XXX_Unmarshal ¶
func (m *UpdateTypeRequest) XXX_Unmarshal(b []byte) error
type UpdateTypeResponse ¶
type UpdateTypeResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateTypeResponse) Descriptor ¶
func (*UpdateTypeResponse) Descriptor() ([]byte, []int)
func (*UpdateTypeResponse) ProtoMessage ¶
func (*UpdateTypeResponse) ProtoMessage()
func (*UpdateTypeResponse) Reset ¶
func (m *UpdateTypeResponse) Reset()
func (*UpdateTypeResponse) String ¶
func (m *UpdateTypeResponse) String() string
func (*UpdateTypeResponse) XXX_DiscardUnknown ¶
func (m *UpdateTypeResponse) XXX_DiscardUnknown()
func (*UpdateTypeResponse) XXX_Marshal ¶
func (m *UpdateTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateTypeResponse) XXX_Merge ¶
func (m *UpdateTypeResponse) XXX_Merge(src proto.Message)
func (*UpdateTypeResponse) XXX_Size ¶
func (m *UpdateTypeResponse) XXX_Size() int
func (*UpdateTypeResponse) XXX_Unmarshal ¶
func (m *UpdateTypeResponse) XXX_Unmarshal(b []byte) error