grpc

package
v0.0.0-...-17ece98 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2020 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterInputServer 

func RegisterInputServer(s *grpc.Server, srv InputServer)

func RegisterListenerServer 

func RegisterListenerServer(s *grpc.Server, srv ListenerServer)

func RegisterSchemaServer 

func RegisterSchemaServer(s *grpc.Server, srv SchemaServer)

func RegisterTemplateServer 

func RegisterTemplateServer(s *grpc.Server, srv TemplateServer)

func Time 

func Time(ts *timestamp.Timestamp) *time.Time

Time converts a google.protobuf.Timestamp proto to a time.Time. It panics if the passed Timestamp is invalid.

func Timestamp 

func Timestamp(tp *time.Time) *timestamp.Timestamp

Timestamp converts a time.Time to a google.protobuf.Timestamp proto. It panics if the resulting Timestamp is invalid.

Types

type CreateSchemaRequest 

type CreateSchemaRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title                string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Definition           string   `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSchemaRequest) Descriptor 

func (*CreateSchemaRequest) Descriptor() ([]byte, []int)

func (*CreateSchemaRequest) GetDefinition 

func (m *CreateSchemaRequest) GetDefinition() string

func (*CreateSchemaRequest) GetId 

func (m *CreateSchemaRequest) GetId() string

func (*CreateSchemaRequest) GetTitle 

func (m *CreateSchemaRequest) GetTitle() string

func (*CreateSchemaRequest) ProtoMessage 

func (*CreateSchemaRequest) ProtoMessage()

func (*CreateSchemaRequest) Reset 

func (m *CreateSchemaRequest) Reset()

func (*CreateSchemaRequest) String 

func (m *CreateSchemaRequest) String() string

func (*CreateSchemaRequest) XXX_DiscardUnknown 

func (m *CreateSchemaRequest) XXX_DiscardUnknown()

func (*CreateSchemaRequest) XXX_Marshal 

func (m *CreateSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSchemaRequest) XXX_Merge 

func (m *CreateSchemaRequest) XXX_Merge(src proto.Message)

func (*CreateSchemaRequest) XXX_Size 

func (m *CreateSchemaRequest) XXX_Size() int

func (*CreateSchemaRequest) XXX_Unmarshal 

func (m *CreateSchemaRequest) XXX_Unmarshal(b []byte) error

type CreateSchemaResponse 

type CreateSchemaResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CreateSchemaResponse) Descriptor 

func (*CreateSchemaResponse) Descriptor() ([]byte, []int)

func (*CreateSchemaResponse) GetCreatedAt 

func (m *CreateSchemaResponse) GetCreatedAt() *timestamp.Timestamp

func (*CreateSchemaResponse) GetId 

func (m *CreateSchemaResponse) GetId() string

func (*CreateSchemaResponse) ProtoMessage 

func (*CreateSchemaResponse) ProtoMessage()

func (*CreateSchemaResponse) Reset 

func (m *CreateSchemaResponse) Reset()

func (*CreateSchemaResponse) String 

func (m *CreateSchemaResponse) String() string

func (*CreateSchemaResponse) XXX_DiscardUnknown 

func (m *CreateSchemaResponse) XXX_DiscardUnknown()

func (*CreateSchemaResponse) XXX_Marshal 

func (m *CreateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSchemaResponse) XXX_Merge 

func (m *CreateSchemaResponse) XXX_Merge(src proto.Message)

func (*CreateSchemaResponse) XXX_Size 

func (m *CreateSchemaResponse) XXX_Size() int

func (*CreateSchemaResponse) XXX_Unmarshal 

func (m *CreateSchemaResponse) XXX_Unmarshal(b []byte) error

type CreateTemplateRequest 

type CreateTemplateRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title                string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Definition           string   `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTemplateRequest) Descriptor 

func (*CreateTemplateRequest) Descriptor() ([]byte, []int)

func (*CreateTemplateRequest) GetDefinition 

func (m *CreateTemplateRequest) GetDefinition() string

func (*CreateTemplateRequest) GetId 

func (m *CreateTemplateRequest) GetId() string

func (*CreateTemplateRequest) GetTitle 

func (m *CreateTemplateRequest) GetTitle() string

func (*CreateTemplateRequest) ProtoMessage 

func (*CreateTemplateRequest) ProtoMessage()

func (*CreateTemplateRequest) Reset 

func (m *CreateTemplateRequest) Reset()

func (*CreateTemplateRequest) String 

func (m *CreateTemplateRequest) String() string

func (*CreateTemplateRequest) XXX_DiscardUnknown 

func (m *CreateTemplateRequest) XXX_DiscardUnknown()

func (*CreateTemplateRequest) XXX_Marshal 

func (m *CreateTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTemplateRequest) XXX_Merge 

func (m *CreateTemplateRequest) XXX_Merge(src proto.Message)

func (*CreateTemplateRequest) XXX_Size 

func (m *CreateTemplateRequest) XXX_Size() int

func (*CreateTemplateRequest) XXX_Unmarshal 

func (m *CreateTemplateRequest) XXX_Unmarshal(b []byte) error

type CreateTemplateResponse 

type CreateTemplateResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CreateTemplateResponse) Descriptor 

func (*CreateTemplateResponse) Descriptor() ([]byte, []int)

func (*CreateTemplateResponse) GetCreatedAt 

func (m *CreateTemplateResponse) GetCreatedAt() *timestamp.Timestamp

func (*CreateTemplateResponse) GetId 

func (m *CreateTemplateResponse) GetId() string

func (*CreateTemplateResponse) ProtoMessage 

func (*CreateTemplateResponse) ProtoMessage()

func (*CreateTemplateResponse) Reset 

func (m *CreateTemplateResponse) Reset()

func (*CreateTemplateResponse) String 

func (m *CreateTemplateResponse) String() string

func (*CreateTemplateResponse) XXX_DiscardUnknown 

func (m *CreateTemplateResponse) XXX_DiscardUnknown()

func (*CreateTemplateResponse) XXX_Marshal 

func (m *CreateTemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTemplateResponse) XXX_Merge 

func (m *CreateTemplateResponse) XXX_Merge(src proto.Message)

func (*CreateTemplateResponse) XXX_Size 

func (m *CreateTemplateResponse) XXX_Size() int

func (*CreateTemplateResponse) XXX_Unmarshal 

func (m *CreateTemplateResponse) XXX_Unmarshal(b []byte) error

type DeleteSchemaRequest 

type DeleteSchemaRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSchemaRequest) Descriptor 

func (*DeleteSchemaRequest) Descriptor() ([]byte, []int)

func (*DeleteSchemaRequest) GetId 

func (m *DeleteSchemaRequest) GetId() string

func (*DeleteSchemaRequest) ProtoMessage 

func (*DeleteSchemaRequest) ProtoMessage()

func (*DeleteSchemaRequest) Reset 

func (m *DeleteSchemaRequest) Reset()

func (*DeleteSchemaRequest) String 

func (m *DeleteSchemaRequest) String() string

func (*DeleteSchemaRequest) XXX_DiscardUnknown 

func (m *DeleteSchemaRequest) XXX_DiscardUnknown()

func (*DeleteSchemaRequest) XXX_Marshal 

func (m *DeleteSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSchemaRequest) XXX_Merge 

func (m *DeleteSchemaRequest) XXX_Merge(src proto.Message)

func (*DeleteSchemaRequest) XXX_Size 

func (m *DeleteSchemaRequest) XXX_Size() int

func (*DeleteSchemaRequest) XXX_Unmarshal 

func (m *DeleteSchemaRequest) XXX_Unmarshal(b []byte) error

type DeleteSchemaResponse 

type DeleteSchemaResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeletedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DeleteSchemaResponse) Descriptor 

func (*DeleteSchemaResponse) Descriptor() ([]byte, []int)

func (*DeleteSchemaResponse) GetDeletedAt 

func (m *DeleteSchemaResponse) GetDeletedAt() *timestamp.Timestamp

func (*DeleteSchemaResponse) GetId 

func (m *DeleteSchemaResponse) GetId() string

func (*DeleteSchemaResponse) ProtoMessage 

func (*DeleteSchemaResponse) ProtoMessage()

func (*DeleteSchemaResponse) Reset 

func (m *DeleteSchemaResponse) Reset()

func (*DeleteSchemaResponse) String 

func (m *DeleteSchemaResponse) String() string

func (*DeleteSchemaResponse) XXX_DiscardUnknown 

func (m *DeleteSchemaResponse) XXX_DiscardUnknown()

func (*DeleteSchemaResponse) XXX_Marshal 

func (m *DeleteSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSchemaResponse) XXX_Merge 

func (m *DeleteSchemaResponse) XXX_Merge(src proto.Message)

func (*DeleteSchemaResponse) XXX_Size 

func (m *DeleteSchemaResponse) XXX_Size() int

func (*DeleteSchemaResponse) XXX_Unmarshal 

func (m *DeleteSchemaResponse) XXX_Unmarshal(b []byte) error

type DeleteTemplateRequest 

type DeleteTemplateRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTemplateRequest) Descriptor 

func (*DeleteTemplateRequest) Descriptor() ([]byte, []int)

func (*DeleteTemplateRequest) GetId 

func (m *DeleteTemplateRequest) GetId() string

func (*DeleteTemplateRequest) ProtoMessage 

func (*DeleteTemplateRequest) ProtoMessage()

func (*DeleteTemplateRequest) Reset 

func (m *DeleteTemplateRequest) Reset()

func (*DeleteTemplateRequest) String 

func (m *DeleteTemplateRequest) String() string

func (*DeleteTemplateRequest) XXX_DiscardUnknown 

func (m *DeleteTemplateRequest) XXX_DiscardUnknown()

func (*DeleteTemplateRequest) XXX_Marshal 

func (m *DeleteTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTemplateRequest) XXX_Merge 

func (m *DeleteTemplateRequest) XXX_Merge(src proto.Message)

func (*DeleteTemplateRequest) XXX_Size 

func (m *DeleteTemplateRequest) XXX_Size() int

func (*DeleteTemplateRequest) XXX_Unmarshal 

func (m *DeleteTemplateRequest) XXX_Unmarshal(b []byte) error

type DeleteTemplateResponse 

type DeleteTemplateResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DeletedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DeleteTemplateResponse) Descriptor 

func (*DeleteTemplateResponse) Descriptor() ([]byte, []int)

func (*DeleteTemplateResponse) GetDeletedAt 

func (m *DeleteTemplateResponse) GetDeletedAt() *timestamp.Timestamp

func (*DeleteTemplateResponse) GetId 

func (m *DeleteTemplateResponse) GetId() string

func (*DeleteTemplateResponse) ProtoMessage 

func (*DeleteTemplateResponse) ProtoMessage()

func (*DeleteTemplateResponse) Reset 

func (m *DeleteTemplateResponse) Reset()

func (*DeleteTemplateResponse) String 

func (m *DeleteTemplateResponse) String() string

func (*DeleteTemplateResponse) XXX_DiscardUnknown 

func (m *DeleteTemplateResponse) XXX_DiscardUnknown()

func (*DeleteTemplateResponse) XXX_Marshal 

func (m *DeleteTemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTemplateResponse) XXX_Merge 

func (m *DeleteTemplateResponse) XXX_Merge(src proto.Message)

func (*DeleteTemplateResponse) XXX_Size 

func (m *DeleteTemplateResponse) XXX_Size() int

func (*DeleteTemplateResponse) XXX_Unmarshal 

func (m *DeleteTemplateResponse) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	Id                   uint32               `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SchemaId             string               `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	InputId              string               `protobuf:"bytes,3,opt,name=input_id,json=inputId,proto3" json:"input_id,omitempty"`
	TemplateId           string               `protobuf:"bytes,4,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
	Identifier           string               `protobuf:"bytes,5,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Context              []byte               `protobuf:"bytes,6,opt,name=context,proto3" json:"context,omitempty"`
	Code                 int32                `protobuf:"varint,7,opt,name=code,proto3" json:"code,omitempty"`
	Url                  string               `protobuf:"bytes,8,opt,name=url,proto3" json:"url,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetCode 

func (m *Event) GetCode() int32

func (*Event) GetContext 

func (m *Event) GetContext() []byte

func (*Event) GetCreatedAt 

func (m *Event) GetCreatedAt() *timestamp.Timestamp

func (*Event) GetId 

func (m *Event) GetId() uint32

func (*Event) GetIdentifier 

func (m *Event) GetIdentifier() string

func (*Event) GetInputId 

func (m *Event) GetInputId() string

func (*Event) GetSchemaId 

func (m *Event) GetSchemaId() string

func (*Event) GetTemplateId 

func (m *Event) GetTemplateId() string

func (*Event) GetUrl 

func (m *Event) GetUrl() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventFilter 

type EventFilter struct {
	SchemaId             string          `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	InputId              string          `protobuf:"bytes,2,opt,name=input_id,json=inputId,proto3" json:"input_id,omitempty"`
	TemplateId           string          `protobuf:"bytes,3,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
	Identifier           string          `protobuf:"bytes,4,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Code                 int32           `protobuf:"varint,5,opt,name=code,proto3" json:"code,omitempty"`
	Url                  string          `protobuf:"bytes,6,opt,name=url,proto3" json:"url,omitempty"`
	CreatedAt            *TimestampRange `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Limit                uint32          `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*EventFilter) Descriptor 

func (*EventFilter) Descriptor() ([]byte, []int)

func (*EventFilter) GetCode 

func (m *EventFilter) GetCode() int32

func (*EventFilter) GetCreatedAt 

func (m *EventFilter) GetCreatedAt() *TimestampRange

func (*EventFilter) GetIdentifier 

func (m *EventFilter) GetIdentifier() string

func (*EventFilter) GetInputId 

func (m *EventFilter) GetInputId() string

func (*EventFilter) GetLimit 

func (m *EventFilter) GetLimit() uint32

func (*EventFilter) GetSchemaId 

func (m *EventFilter) GetSchemaId() string

func (*EventFilter) GetTemplateId 

func (m *EventFilter) GetTemplateId() string

func (*EventFilter) GetUrl 

func (m *EventFilter) GetUrl() string

func (*EventFilter) ProtoMessage 

func (*EventFilter) ProtoMessage()

func (*EventFilter) Reset 

func (m *EventFilter) Reset()

func (*EventFilter) String 

func (m *EventFilter) String() string

func (*EventFilter) XXX_DiscardUnknown 

func (m *EventFilter) XXX_DiscardUnknown()

func (*EventFilter) XXX_Marshal 

func (m *EventFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventFilter) XXX_Merge 

func (m *EventFilter) XXX_Merge(src proto.Message)

func (*EventFilter) XXX_Size 

func (m *EventFilter) XXX_Size() int

func (*EventFilter) XXX_Unmarshal 

func (m *EventFilter) XXX_Unmarshal(b []byte) error

type InputClient 

type InputClient interface {
	Read(ctx context.Context, in *ReadInputRequest, opts ...grpc.CallOption) (*ReadInputResponse, error)
}

InputClient is the client API for Input service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInputClient 

func NewInputClient(cc *grpc.ClientConn) InputClient

type InputEntry 

type InputEntry struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	SchemaId             string               `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	Data                 string               `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*InputEntry) Descriptor 

func (*InputEntry) Descriptor() ([]byte, []int)

func (*InputEntry) GetCreatedAt 

func (m *InputEntry) GetCreatedAt() *timestamp.Timestamp

func (*InputEntry) GetData 

func (m *InputEntry) GetData() string

func (*InputEntry) GetId 

func (m *InputEntry) GetId() string

func (*InputEntry) GetSchemaId 

func (m *InputEntry) GetSchemaId() string

func (*InputEntry) ProtoMessage 

func (*InputEntry) ProtoMessage()

func (*InputEntry) Reset 

func (m *InputEntry) Reset()

func (*InputEntry) String 

func (m *InputEntry) String() string

func (*InputEntry) XXX_DiscardUnknown 

func (m *InputEntry) XXX_DiscardUnknown()

func (*InputEntry) XXX_Marshal 

func (m *InputEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InputEntry) XXX_Merge 

func (m *InputEntry) XXX_Merge(src proto.Message)

func (*InputEntry) XXX_Size 

func (m *InputEntry) XXX_Size() int

func (*InputEntry) XXX_Unmarshal 

func (m *InputEntry) XXX_Unmarshal(b []byte) error

type InputFilter 

type InputFilter struct {
	SchemaId             string          `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	CreatedAt            *TimestampRange `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*InputFilter) Descriptor 

func (*InputFilter) Descriptor() ([]byte, []int)

func (*InputFilter) GetCreatedAt 

func (m *InputFilter) GetCreatedAt() *TimestampRange

func (*InputFilter) GetSchemaId 

func (m *InputFilter) GetSchemaId() string

func (*InputFilter) ProtoMessage 

func (*InputFilter) ProtoMessage()

func (*InputFilter) Reset 

func (m *InputFilter) Reset()

func (*InputFilter) String 

func (m *InputFilter) String() string

func (*InputFilter) XXX_DiscardUnknown 

func (m *InputFilter) XXX_DiscardUnknown()

func (*InputFilter) XXX_Marshal 

func (m *InputFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InputFilter) XXX_Merge 

func (m *InputFilter) XXX_Merge(src proto.Message)

func (*InputFilter) XXX_Size 

func (m *InputFilter) XXX_Size() int

func (*InputFilter) XXX_Unmarshal 

func (m *InputFilter) XXX_Unmarshal(b []byte) error

type InputServer 

type InputServer interface {
	Read(context.Context, *ReadInputRequest) (*ReadInputResponse, error)
}

InputServer is the server API for Input service.

func NewInputServer 

func NewInputServer(storage ProtectedStorage) InputServer

NewInputServer returns new instance of server API for Input service.

type ListenEventsRequest 

type ListenEventsRequest struct {
	Filter               *EventFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListenEventsRequest) Descriptor 

func (*ListenEventsRequest) Descriptor() ([]byte, []int)

func (*ListenEventsRequest) GetFilter 

func (m *ListenEventsRequest) GetFilter() *EventFilter

func (*ListenEventsRequest) ProtoMessage 

func (*ListenEventsRequest) ProtoMessage()

func (*ListenEventsRequest) Reset 

func (m *ListenEventsRequest) Reset()

func (*ListenEventsRequest) String 

func (m *ListenEventsRequest) String() string

func (*ListenEventsRequest) XXX_DiscardUnknown 

func (m *ListenEventsRequest) XXX_DiscardUnknown()

func (*ListenEventsRequest) XXX_Marshal 

func (m *ListenEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenEventsRequest) XXX_Merge 

func (m *ListenEventsRequest) XXX_Merge(src proto.Message)

func (*ListenEventsRequest) XXX_Size 

func (m *ListenEventsRequest) XXX_Size() int

func (*ListenEventsRequest) XXX_Unmarshal 

func (m *ListenEventsRequest) XXX_Unmarshal(b []byte) error

type ListenerClient 

type ListenerClient interface {
	Read(ctx context.Context, in *ReadEventsRequest, opts ...grpc.CallOption) (*ReadEventsResponse, error)
	Listen(ctx context.Context, in *ListenEventsRequest, opts ...grpc.CallOption) (Listener_ListenClient, error)
}

ListenerClient is the client API for Listener service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewListenerClient 

func NewListenerClient(cc *grpc.ClientConn) ListenerClient

type ListenerServer 

type ListenerServer interface {
	Read(context.Context, *ReadEventsRequest) (*ReadEventsResponse, error)
	Listen(*ListenEventsRequest, Listener_ListenServer) error
}

ListenerServer is the server API for Listener service.

func NewEventServer 

func NewEventServer(storage ProtectedStorage) ListenerServer

NewEventServer returns new instance of server API for Log service.

type Listener_ListenClient 

type Listener_ListenClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Listener_ListenServer 

type Listener_ListenServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type ProtectedStorage 

type ProtectedStorage interface {
	// CreateSchema TODO issue#173
	CreateSchema(ctx context.Context, tokenID domain.ID, data query.CreateSchema) (types.Schema, error)
	// ReadSchema TODO issue#173
	ReadSchema(ctx context.Context, tokenID domain.ID, data query.ReadSchema) (types.Schema, error)
	// UpdateSchema TODO issue#173
	UpdateSchema(ctx context.Context, tokenID domain.ID, data query.UpdateSchema) (types.Schema, error)
	// DeleteSchema TODO issue#173
	DeleteSchema(ctx context.Context, tokenID domain.ID, data query.DeleteSchema) (types.Schema, error)

	// CreateTemplate TODO issue#173
	CreateTemplate(ctx context.Context, tokenID domain.ID, data query.CreateTemplate) (types.Template, error)
	// ReadTemplate TODO issue#173
	ReadTemplate(ctx context.Context, tokenID domain.ID, data query.ReadTemplate) (types.Template, error)
	// UpdateTemplate TODO issue#173
	UpdateTemplate(ctx context.Context, tokenID domain.ID, data query.UpdateTemplate) (types.Template, error)
	// DeleteTemplate TODO issue#173
	DeleteTemplate(ctx context.Context, tokenID domain.ID, data query.DeleteTemplate) (types.Template, error)

	// ReadInputByID TODO issue#173
	ReadInputByID(ctx context.Context, tokenID, id domain.ID) (types.Input, error)
	// ReadInputByFilter TODO issue#173
	ReadInputByFilter(ctx context.Context, tokenID domain.ID, data query.InputFilter) ([]types.Input, error)
}

ProtectedStorage TODO issue#173

type ReadEventsRequest 

type ReadEventsRequest struct {
	// Types that are valid to be assigned to Filter:
	//	*ReadEventsRequest_Id
	//	*ReadEventsRequest_Condition
	Filter               isReadEventsRequest_Filter `protobuf_oneof:"filter"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ReadEventsRequest) Descriptor 

func (*ReadEventsRequest) Descriptor() ([]byte, []int)

func (*ReadEventsRequest) GetCondition 

func (m *ReadEventsRequest) GetCondition() *EventFilter

func (*ReadEventsRequest) GetFilter 

func (m *ReadEventsRequest) GetFilter() isReadEventsRequest_Filter

func (*ReadEventsRequest) GetId 

func (m *ReadEventsRequest) GetId() uint32

func (*ReadEventsRequest) ProtoMessage 

func (*ReadEventsRequest) ProtoMessage()

func (*ReadEventsRequest) Reset 

func (m *ReadEventsRequest) Reset()

func (*ReadEventsRequest) String 

func (m *ReadEventsRequest) String() string

func (*ReadEventsRequest) XXX_DiscardUnknown 

func (m *ReadEventsRequest) XXX_DiscardUnknown()

func (*ReadEventsRequest) XXX_Marshal 

func (m *ReadEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadEventsRequest) XXX_Merge 

func (m *ReadEventsRequest) XXX_Merge(src proto.Message)

func (*ReadEventsRequest) XXX_OneofFuncs 

func (*ReadEventsRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ReadEventsRequest) XXX_Size 

func (m *ReadEventsRequest) XXX_Size() int

func (*ReadEventsRequest) XXX_Unmarshal 

func (m *ReadEventsRequest) XXX_Unmarshal(b []byte) error

type ReadEventsRequest_Condition 

type ReadEventsRequest_Condition struct {
	Condition *EventFilter `protobuf:"bytes,2,opt,name=condition,proto3,oneof"`
}

type ReadEventsRequest_Id 

type ReadEventsRequest_Id struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3,oneof"`
}

type ReadEventsResponse 

type ReadEventsResponse struct {
	Events               []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadEventsResponse) Descriptor 

func (*ReadEventsResponse) Descriptor() ([]byte, []int)

func (*ReadEventsResponse) GetEvents 

func (m *ReadEventsResponse) GetEvents() []*Event

func (*ReadEventsResponse) ProtoMessage 

func (*ReadEventsResponse) ProtoMessage()

func (*ReadEventsResponse) Reset 

func (m *ReadEventsResponse) Reset()

func (*ReadEventsResponse) String 

func (m *ReadEventsResponse) String() string

func (*ReadEventsResponse) XXX_DiscardUnknown 

func (m *ReadEventsResponse) XXX_DiscardUnknown()

func (*ReadEventsResponse) XXX_Marshal 

func (m *ReadEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadEventsResponse) XXX_Merge 

func (m *ReadEventsResponse) XXX_Merge(src proto.Message)

func (*ReadEventsResponse) XXX_Size 

func (m *ReadEventsResponse) XXX_Size() int

func (*ReadEventsResponse) XXX_Unmarshal 

func (m *ReadEventsResponse) XXX_Unmarshal(b []byte) error

type ReadInputRequest 

type ReadInputRequest struct {
	// Types that are valid to be assigned to Filter:
	//	*ReadInputRequest_Id
	//	*ReadInputRequest_Condition
	Filter               isReadInputRequest_Filter `protobuf_oneof:"filter"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ReadInputRequest) Descriptor 

func (*ReadInputRequest) Descriptor() ([]byte, []int)

func (*ReadInputRequest) GetCondition 

func (m *ReadInputRequest) GetCondition() *InputFilter

func (*ReadInputRequest) GetFilter 

func (m *ReadInputRequest) GetFilter() isReadInputRequest_Filter

func (*ReadInputRequest) GetId 

func (m *ReadInputRequest) GetId() string

func (*ReadInputRequest) ProtoMessage 

func (*ReadInputRequest) ProtoMessage()

func (*ReadInputRequest) Reset 

func (m *ReadInputRequest) Reset()

func (*ReadInputRequest) String 

func (m *ReadInputRequest) String() string

func (*ReadInputRequest) XXX_DiscardUnknown 

func (m *ReadInputRequest) XXX_DiscardUnknown()

func (*ReadInputRequest) XXX_Marshal 

func (m *ReadInputRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInputRequest) XXX_Merge 

func (m *ReadInputRequest) XXX_Merge(src proto.Message)

func (*ReadInputRequest) XXX_OneofFuncs 

func (*ReadInputRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ReadInputRequest) XXX_Size 

func (m *ReadInputRequest) XXX_Size() int

func (*ReadInputRequest) XXX_Unmarshal 

func (m *ReadInputRequest) XXX_Unmarshal(b []byte) error

type ReadInputRequest_Condition 

type ReadInputRequest_Condition struct {
	Condition *InputFilter `protobuf:"bytes,2,opt,name=condition,proto3,oneof"`
}

type ReadInputRequest_Id 

type ReadInputRequest_Id struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3,oneof"`
}

type ReadInputResponse 

type ReadInputResponse struct {
	Entries              []*InputEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ReadInputResponse) Descriptor 

func (*ReadInputResponse) Descriptor() ([]byte, []int)

func (*ReadInputResponse) GetEntries 

func (m *ReadInputResponse) GetEntries() []*InputEntry

func (*ReadInputResponse) ProtoMessage 

func (*ReadInputResponse) ProtoMessage()

func (*ReadInputResponse) Reset 

func (m *ReadInputResponse) Reset()

func (*ReadInputResponse) String 

func (m *ReadInputResponse) String() string

func (*ReadInputResponse) XXX_DiscardUnknown 

func (m *ReadInputResponse) XXX_DiscardUnknown()

func (*ReadInputResponse) XXX_Marshal 

func (m *ReadInputResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadInputResponse) XXX_Merge 

func (m *ReadInputResponse) XXX_Merge(src proto.Message)

func (*ReadInputResponse) XXX_Size 

func (m *ReadInputResponse) XXX_Size() int

func (*ReadInputResponse) XXX_Unmarshal 

func (m *ReadInputResponse) XXX_Unmarshal(b []byte) error

type ReadSchemaRequest 

type ReadSchemaRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadSchemaRequest) Descriptor 

func (*ReadSchemaRequest) Descriptor() ([]byte, []int)

func (*ReadSchemaRequest) GetId 

func (m *ReadSchemaRequest) GetId() string

func (*ReadSchemaRequest) ProtoMessage 

func (*ReadSchemaRequest) ProtoMessage()

func (*ReadSchemaRequest) Reset 

func (m *ReadSchemaRequest) Reset()

func (*ReadSchemaRequest) String 

func (m *ReadSchemaRequest) String() string

func (*ReadSchemaRequest) XXX_DiscardUnknown 

func (m *ReadSchemaRequest) XXX_DiscardUnknown()

func (*ReadSchemaRequest) XXX_Marshal 

func (m *ReadSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSchemaRequest) XXX_Merge 

func (m *ReadSchemaRequest) XXX_Merge(src proto.Message)

func (*ReadSchemaRequest) XXX_Size 

func (m *ReadSchemaRequest) XXX_Size() int

func (*ReadSchemaRequest) XXX_Unmarshal 

func (m *ReadSchemaRequest) XXX_Unmarshal(b []byte) error

type ReadSchemaResponse 

type ReadSchemaResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title                string               `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Definition           string               `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReadSchemaResponse) Descriptor 

func (*ReadSchemaResponse) Descriptor() ([]byte, []int)

func (*ReadSchemaResponse) GetCreatedAt 

func (m *ReadSchemaResponse) GetCreatedAt() *timestamp.Timestamp

func (*ReadSchemaResponse) GetDefinition 

func (m *ReadSchemaResponse) GetDefinition() string

func (*ReadSchemaResponse) GetDeletedAt 

func (m *ReadSchemaResponse) GetDeletedAt() *timestamp.Timestamp

func (*ReadSchemaResponse) GetId 

func (m *ReadSchemaResponse) GetId() string

func (*ReadSchemaResponse) GetTitle 

func (m *ReadSchemaResponse) GetTitle() string

func (*ReadSchemaResponse) GetUpdatedAt 

func (m *ReadSchemaResponse) GetUpdatedAt() *timestamp.Timestamp

func (*ReadSchemaResponse) ProtoMessage 

func (*ReadSchemaResponse) ProtoMessage()

func (*ReadSchemaResponse) Reset 

func (m *ReadSchemaResponse) Reset()

func (*ReadSchemaResponse) String 

func (m *ReadSchemaResponse) String() string

func (*ReadSchemaResponse) XXX_DiscardUnknown 

func (m *ReadSchemaResponse) XXX_DiscardUnknown()

func (*ReadSchemaResponse) XXX_Marshal 

func (m *ReadSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSchemaResponse) XXX_Merge 

func (m *ReadSchemaResponse) XXX_Merge(src proto.Message)

func (*ReadSchemaResponse) XXX_Size 

func (m *ReadSchemaResponse) XXX_Size() int

func (*ReadSchemaResponse) XXX_Unmarshal 

func (m *ReadSchemaResponse) XXX_Unmarshal(b []byte) error

type ReadTemplateRequest 

type ReadTemplateRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadTemplateRequest) Descriptor 

func (*ReadTemplateRequest) Descriptor() ([]byte, []int)

func (*ReadTemplateRequest) GetId 

func (m *ReadTemplateRequest) GetId() string

func (*ReadTemplateRequest) ProtoMessage 

func (*ReadTemplateRequest) ProtoMessage()

func (*ReadTemplateRequest) Reset 

func (m *ReadTemplateRequest) Reset()

func (*ReadTemplateRequest) String 

func (m *ReadTemplateRequest) String() string

func (*ReadTemplateRequest) XXX_DiscardUnknown 

func (m *ReadTemplateRequest) XXX_DiscardUnknown()

func (*ReadTemplateRequest) XXX_Marshal 

func (m *ReadTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTemplateRequest) XXX_Merge 

func (m *ReadTemplateRequest) XXX_Merge(src proto.Message)

func (*ReadTemplateRequest) XXX_Size 

func (m *ReadTemplateRequest) XXX_Size() int

func (*ReadTemplateRequest) XXX_Unmarshal 

func (m *ReadTemplateRequest) XXX_Unmarshal(b []byte) error

type ReadTemplateResponse 

type ReadTemplateResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title                string               `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Definition           string               `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DeletedAt            *timestamp.Timestamp `protobuf:"bytes,6,opt,name=deleted_at,json=deletedAt,proto3" json:"deleted_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ReadTemplateResponse) Descriptor 

func (*ReadTemplateResponse) Descriptor() ([]byte, []int)

func (*ReadTemplateResponse) GetCreatedAt 

func (m *ReadTemplateResponse) GetCreatedAt() *timestamp.Timestamp

func (*ReadTemplateResponse) GetDefinition 

func (m *ReadTemplateResponse) GetDefinition() string

func (*ReadTemplateResponse) GetDeletedAt 

func (m *ReadTemplateResponse) GetDeletedAt() *timestamp.Timestamp

func (*ReadTemplateResponse) GetId 

func (m *ReadTemplateResponse) GetId() string

func (*ReadTemplateResponse) GetTitle 

func (m *ReadTemplateResponse) GetTitle() string

func (*ReadTemplateResponse) GetUpdatedAt 

func (m *ReadTemplateResponse) GetUpdatedAt() *timestamp.Timestamp

func (*ReadTemplateResponse) ProtoMessage 

func (*ReadTemplateResponse) ProtoMessage()

func (*ReadTemplateResponse) Reset 

func (m *ReadTemplateResponse) Reset()

func (*ReadTemplateResponse) String 

func (m *ReadTemplateResponse) String() string

func (*ReadTemplateResponse) XXX_DiscardUnknown 

func (m *ReadTemplateResponse) XXX_DiscardUnknown()

func (*ReadTemplateResponse) XXX_Marshal 

func (m *ReadTemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTemplateResponse) XXX_Merge 

func (m *ReadTemplateResponse) XXX_Merge(src proto.Message)

func (*ReadTemplateResponse) XXX_Size 

func (m *ReadTemplateResponse) XXX_Size() int

func (*ReadTemplateResponse) XXX_Unmarshal 

func (m *ReadTemplateResponse) XXX_Unmarshal(b []byte) error

type SchemaClient 

type SchemaClient interface {
	Create(ctx context.Context, in *CreateSchemaRequest, opts ...grpc.CallOption) (*CreateSchemaResponse, error)
	Read(ctx context.Context, in *ReadSchemaRequest, opts ...grpc.CallOption) (*ReadSchemaResponse, error)
	Update(ctx context.Context, in *UpdateSchemaRequest, opts ...grpc.CallOption) (*UpdateSchemaResponse, error)
	Delete(ctx context.Context, in *DeleteSchemaRequest, opts ...grpc.CallOption) (*DeleteSchemaResponse, error)
}

SchemaClient is the client API for Schema service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchemaClient 

func NewSchemaClient(cc *grpc.ClientConn) SchemaClient

type SchemaServer 

type SchemaServer interface {
	Create(context.Context, *CreateSchemaRequest) (*CreateSchemaResponse, error)
	Read(context.Context, *ReadSchemaRequest) (*ReadSchemaResponse, error)
	Update(context.Context, *UpdateSchemaRequest) (*UpdateSchemaResponse, error)
	Delete(context.Context, *DeleteSchemaRequest) (*DeleteSchemaResponse, error)
}

SchemaServer is the server API for Schema service.

func NewSchemaServer 

func NewSchemaServer(storage ProtectedStorage) SchemaServer

NewSchemaServer returns new instance of server API for Schema service.

type TemplateClient 

type TemplateClient interface {
	Create(ctx context.Context, in *CreateTemplateRequest, opts ...grpc.CallOption) (*CreateTemplateResponse, error)
	Read(ctx context.Context, in *ReadTemplateRequest, opts ...grpc.CallOption) (*ReadTemplateResponse, error)
	Update(ctx context.Context, in *UpdateTemplateRequest, opts ...grpc.CallOption) (*UpdateTemplateResponse, error)
	Delete(ctx context.Context, in *DeleteTemplateRequest, opts ...grpc.CallOption) (*DeleteTemplateResponse, error)
}

TemplateClient is the client API for Template service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTemplateClient 

func NewTemplateClient(cc *grpc.ClientConn) TemplateClient

type TemplateServer 

type TemplateServer interface {
	Create(context.Context, *CreateTemplateRequest) (*CreateTemplateResponse, error)
	Read(context.Context, *ReadTemplateRequest) (*ReadTemplateResponse, error)
	Update(context.Context, *UpdateTemplateRequest) (*UpdateTemplateResponse, error)
	Delete(context.Context, *DeleteTemplateRequest) (*DeleteTemplateResponse, error)
}

TemplateServer is the server API for Template service.

func NewTemplateServer 

func NewTemplateServer(storage ProtectedStorage) TemplateServer

NewTemplateServer returns new instance of server API for Template service.

type TimestampRange 

type TimestampRange struct {
	Start                *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TimestampRange) Descriptor 

func (*TimestampRange) Descriptor() ([]byte, []int)

func (*TimestampRange) GetEnd 

func (m *TimestampRange) GetEnd() *timestamp.Timestamp

func (*TimestampRange) GetStart 

func (m *TimestampRange) GetStart() *timestamp.Timestamp

func (*TimestampRange) ProtoMessage 

func (*TimestampRange) ProtoMessage()

func (*TimestampRange) Reset 

func (m *TimestampRange) Reset()

func (*TimestampRange) String 

func (m *TimestampRange) String() string

func (*TimestampRange) XXX_DiscardUnknown 

func (m *TimestampRange) XXX_DiscardUnknown()

func (*TimestampRange) XXX_Marshal 

func (m *TimestampRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimestampRange) XXX_Merge 

func (m *TimestampRange) XXX_Merge(src proto.Message)

func (*TimestampRange) XXX_Size 

func (m *TimestampRange) XXX_Size() int

func (*TimestampRange) XXX_Unmarshal 

func (m *TimestampRange) XXX_Unmarshal(b []byte) error

type UpdateSchemaRequest 

type UpdateSchemaRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title                string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Definition           string   `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateSchemaRequest) Descriptor 

func (*UpdateSchemaRequest) Descriptor() ([]byte, []int)

func (*UpdateSchemaRequest) GetDefinition 

func (m *UpdateSchemaRequest) GetDefinition() string

func (*UpdateSchemaRequest) GetId 

func (m *UpdateSchemaRequest) GetId() string

func (*UpdateSchemaRequest) GetTitle 

func (m *UpdateSchemaRequest) GetTitle() string

func (*UpdateSchemaRequest) ProtoMessage 

func (*UpdateSchemaRequest) ProtoMessage()

func (*UpdateSchemaRequest) Reset 

func (m *UpdateSchemaRequest) Reset()

func (*UpdateSchemaRequest) String 

func (m *UpdateSchemaRequest) String() string

func (*UpdateSchemaRequest) XXX_DiscardUnknown 

func (m *UpdateSchemaRequest) XXX_DiscardUnknown()

func (*UpdateSchemaRequest) XXX_Marshal 

func (m *UpdateSchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSchemaRequest) XXX_Merge 

func (m *UpdateSchemaRequest) XXX_Merge(src proto.Message)

func (*UpdateSchemaRequest) XXX_Size 

func (m *UpdateSchemaRequest) XXX_Size() int

func (*UpdateSchemaRequest) XXX_Unmarshal 

func (m *UpdateSchemaRequest) XXX_Unmarshal(b []byte) error

type UpdateSchemaResponse 

type UpdateSchemaResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UpdateSchemaResponse) Descriptor 

func (*UpdateSchemaResponse) Descriptor() ([]byte, []int)

func (*UpdateSchemaResponse) GetId 

func (m *UpdateSchemaResponse) GetId() string

func (*UpdateSchemaResponse) GetUpdatedAt 

func (m *UpdateSchemaResponse) GetUpdatedAt() *timestamp.Timestamp

func (*UpdateSchemaResponse) ProtoMessage 

func (*UpdateSchemaResponse) ProtoMessage()

func (*UpdateSchemaResponse) Reset 

func (m *UpdateSchemaResponse) Reset()

func (*UpdateSchemaResponse) String 

func (m *UpdateSchemaResponse) String() string

func (*UpdateSchemaResponse) XXX_DiscardUnknown 

func (m *UpdateSchemaResponse) XXX_DiscardUnknown()

func (*UpdateSchemaResponse) XXX_Marshal 

func (m *UpdateSchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSchemaResponse) XXX_Merge 

func (m *UpdateSchemaResponse) XXX_Merge(src proto.Message)

func (*UpdateSchemaResponse) XXX_Size 

func (m *UpdateSchemaResponse) XXX_Size() int

func (*UpdateSchemaResponse) XXX_Unmarshal 

func (m *UpdateSchemaResponse) XXX_Unmarshal(b []byte) error

type UpdateTemplateRequest 

type UpdateTemplateRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Title                string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Definition           string   `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateTemplateRequest) Descriptor 

func (*UpdateTemplateRequest) Descriptor() ([]byte, []int)

func (*UpdateTemplateRequest) GetDefinition 

func (m *UpdateTemplateRequest) GetDefinition() string

func (*UpdateTemplateRequest) GetId 

func (m *UpdateTemplateRequest) GetId() string

func (*UpdateTemplateRequest) GetTitle 

func (m *UpdateTemplateRequest) GetTitle() string

func (*UpdateTemplateRequest) ProtoMessage 

func (*UpdateTemplateRequest) ProtoMessage()

func (*UpdateTemplateRequest) Reset 

func (m *UpdateTemplateRequest) Reset()

func (*UpdateTemplateRequest) String 

func (m *UpdateTemplateRequest) String() string

func (*UpdateTemplateRequest) XXX_DiscardUnknown 

func (m *UpdateTemplateRequest) XXX_DiscardUnknown()

func (*UpdateTemplateRequest) XXX_Marshal 

func (m *UpdateTemplateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTemplateRequest) XXX_Merge 

func (m *UpdateTemplateRequest) XXX_Merge(src proto.Message)

func (*UpdateTemplateRequest) XXX_Size 

func (m *UpdateTemplateRequest) XXX_Size() int

func (*UpdateTemplateRequest) XXX_Unmarshal 

func (m *UpdateTemplateRequest) XXX_Unmarshal(b []byte) error

type UpdateTemplateResponse 

type UpdateTemplateResponse struct {
	Id                   string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UpdateTemplateResponse) Descriptor 

func (*UpdateTemplateResponse) Descriptor() ([]byte, []int)

func (*UpdateTemplateResponse) GetId 

func (m *UpdateTemplateResponse) GetId() string

func (*UpdateTemplateResponse) GetUpdatedAt 

func (m *UpdateTemplateResponse) GetUpdatedAt() *timestamp.Timestamp

func (*UpdateTemplateResponse) ProtoMessage 

func (*UpdateTemplateResponse) ProtoMessage()

func (*UpdateTemplateResponse) Reset 

func (m *UpdateTemplateResponse) Reset()

func (*UpdateTemplateResponse) String 

func (m *UpdateTemplateResponse) String() string

func (*UpdateTemplateResponse) XXX_DiscardUnknown 

func (m *UpdateTemplateResponse) XXX_DiscardUnknown()

func (*UpdateTemplateResponse) XXX_Marshal 

func (m *UpdateTemplateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTemplateResponse) XXX_Merge 

func (m *UpdateTemplateResponse) XXX_Merge(src proto.Message)

func (*UpdateTemplateResponse) XXX_Size 

func (m *UpdateTemplateResponse) XXX_Size() int

func (*UpdateTemplateResponse) XXX_Unmarshal 

func (m *UpdateTemplateResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.