data

package module
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2020 License: GPL-3.0 Imports: 17 Imported by: 1

README

Phi Suite Data.gw

Homepage https://phisuite.com
GitHub https://github.com/phisuite

Overview

This project contains the Go module to create the Data http gateway.
For more details, see Phi Suite Data.

Installation

go get github.com/phisuite/data.gw

Creating the gateway

package main
import "github.com/phisuite/data.gw"

conn, err := grpc.DialContext(ctx, "localhost:50051")
defer conn.Close()

router := runtime.NewServeMux()
err = data.RegisterEventAPIHandler(ctx, router, conn)
err = http.ListenAndServe(":8080", router)

For more details, see grpc-gateway.

Documentation

Overview

Package data is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package data is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package data is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_entity_proto protoreflect.FileDescriptor
View Source 
var File_event_proto protoreflect.FileDescriptor
View Source 
var File_process_proto protoreflect.FileDescriptor

Functions

func RegisterEntityReadAPIHandler 

func RegisterEntityReadAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEntityReadAPIHandler registers the http handlers for service EntityReadAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEntityReadAPIHandlerClient 

func RegisterEntityReadAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EntityReadAPIClient) error

RegisterEntityReadAPIHandlerClient registers the http handlers for service EntityReadAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EntityReadAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EntityReadAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EntityReadAPIClient" to call the correct interceptors.

func RegisterEntityReadAPIHandlerFromEndpoint 

func RegisterEntityReadAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEntityReadAPIHandlerFromEndpoint is same as RegisterEntityReadAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEntityReadAPIHandlerServer 

func RegisterEntityReadAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EntityReadAPIServer) error

RegisterEntityReadAPIHandlerServer registers the http handlers for service EntityReadAPI to "mux". UnaryRPC :call EntityReadAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEntityReadAPIServer 

func RegisterEntityReadAPIServer(s *grpc.Server, srv EntityReadAPIServer)

func RegisterEntityWriteAPIHandler 

func RegisterEntityWriteAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEntityWriteAPIHandler registers the http handlers for service EntityWriteAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEntityWriteAPIHandlerClient 

func RegisterEntityWriteAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EntityWriteAPIClient) error

RegisterEntityWriteAPIHandlerClient registers the http handlers for service EntityWriteAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EntityWriteAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EntityWriteAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EntityWriteAPIClient" to call the correct interceptors.

func RegisterEntityWriteAPIHandlerFromEndpoint 

func RegisterEntityWriteAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEntityWriteAPIHandlerFromEndpoint is same as RegisterEntityWriteAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEntityWriteAPIHandlerServer 

func RegisterEntityWriteAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EntityWriteAPIServer) error

RegisterEntityWriteAPIHandlerServer registers the http handlers for service EntityWriteAPI to "mux". UnaryRPC :call EntityWriteAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEntityWriteAPIServer 

func RegisterEntityWriteAPIServer(s *grpc.Server, srv EntityWriteAPIServer)

func RegisterEventAPIHandler 

func RegisterEventAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventAPIHandler registers the http handlers for service EventAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventAPIHandlerClient 

func RegisterEventAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventAPIClient) error

RegisterEventAPIHandlerClient registers the http handlers for service EventAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventAPIClient" to call the correct interceptors.

func RegisterEventAPIHandlerFromEndpoint 

func RegisterEventAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventAPIHandlerFromEndpoint is same as RegisterEventAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventAPIHandlerServer 

func RegisterEventAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventAPIServer) error

RegisterEventAPIHandlerServer registers the http handlers for service EventAPI to "mux". UnaryRPC :call EventAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEventAPIServer 

func RegisterEventAPIServer(s *grpc.Server, srv EventAPIServer)

func RegisterEventReadAPIHandler 

func RegisterEventReadAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventReadAPIHandler registers the http handlers for service EventReadAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventReadAPIHandlerClient 

func RegisterEventReadAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventReadAPIClient) error

RegisterEventReadAPIHandlerClient registers the http handlers for service EventReadAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventReadAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventReadAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventReadAPIClient" to call the correct interceptors.

func RegisterEventReadAPIHandlerFromEndpoint 

func RegisterEventReadAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventReadAPIHandlerFromEndpoint is same as RegisterEventReadAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventReadAPIHandlerServer 

func RegisterEventReadAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventReadAPIServer) error

RegisterEventReadAPIHandlerServer registers the http handlers for service EventReadAPI to "mux". UnaryRPC :call EventReadAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEventReadAPIServer 

func RegisterEventReadAPIServer(s *grpc.Server, srv EventReadAPIServer)

func RegisterEventWriteAPIHandler 

func RegisterEventWriteAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEventWriteAPIHandler registers the http handlers for service EventWriteAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEventWriteAPIHandlerClient 

func RegisterEventWriteAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventWriteAPIClient) error

RegisterEventWriteAPIHandlerClient registers the http handlers for service EventWriteAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EventWriteAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EventWriteAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EventWriteAPIClient" to call the correct interceptors.

func RegisterEventWriteAPIHandlerFromEndpoint 

func RegisterEventWriteAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEventWriteAPIHandlerFromEndpoint is same as RegisterEventWriteAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEventWriteAPIHandlerServer 

func RegisterEventWriteAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventWriteAPIServer) error

RegisterEventWriteAPIHandlerServer registers the http handlers for service EventWriteAPI to "mux". UnaryRPC :call EventWriteAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEventWriteAPIServer 

func RegisterEventWriteAPIServer(s *grpc.Server, srv EventWriteAPIServer)

func RegisterProcessAPIHandler 

func RegisterProcessAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProcessAPIHandler registers the http handlers for service ProcessAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProcessAPIHandlerClient 

func RegisterProcessAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProcessAPIClient) error

RegisterProcessAPIHandlerClient registers the http handlers for service ProcessAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProcessAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProcessAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProcessAPIClient" to call the correct interceptors.

func RegisterProcessAPIHandlerFromEndpoint 

func RegisterProcessAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProcessAPIHandlerFromEndpoint is same as RegisterProcessAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProcessAPIHandlerServer 

func RegisterProcessAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProcessAPIServer) error

RegisterProcessAPIHandlerServer registers the http handlers for service ProcessAPI to "mux". UnaryRPC :call ProcessAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterProcessAPIServer 

func RegisterProcessAPIServer(s *grpc.Server, srv ProcessAPIServer)

func RegisterProcessReadAPIHandler 

func RegisterProcessReadAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProcessReadAPIHandler registers the http handlers for service ProcessReadAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProcessReadAPIHandlerClient 

func RegisterProcessReadAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProcessReadAPIClient) error

RegisterProcessReadAPIHandlerClient registers the http handlers for service ProcessReadAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProcessReadAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProcessReadAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProcessReadAPIClient" to call the correct interceptors.

func RegisterProcessReadAPIHandlerFromEndpoint 

func RegisterProcessReadAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProcessReadAPIHandlerFromEndpoint is same as RegisterProcessReadAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProcessReadAPIHandlerServer 

func RegisterProcessReadAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProcessReadAPIServer) error

RegisterProcessReadAPIHandlerServer registers the http handlers for service ProcessReadAPI to "mux". UnaryRPC :call ProcessReadAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterProcessReadAPIServer 

func RegisterProcessReadAPIServer(s *grpc.Server, srv ProcessReadAPIServer)

func RegisterProcessWriteAPIHandler 

func RegisterProcessWriteAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProcessWriteAPIHandler registers the http handlers for service ProcessWriteAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProcessWriteAPIHandlerClient 

func RegisterProcessWriteAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProcessWriteAPIClient) error

RegisterProcessWriteAPIHandlerClient registers the http handlers for service ProcessWriteAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProcessWriteAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProcessWriteAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProcessWriteAPIClient" to call the correct interceptors.

func RegisterProcessWriteAPIHandlerFromEndpoint 

func RegisterProcessWriteAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProcessWriteAPIHandlerFromEndpoint is same as RegisterProcessWriteAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProcessWriteAPIHandlerServer 

func RegisterProcessWriteAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProcessWriteAPIServer) error

RegisterProcessWriteAPIHandlerServer registers the http handlers for service ProcessWriteAPI to "mux". UnaryRPC :call ProcessWriteAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterProcessWriteAPIServer 

func RegisterProcessWriteAPIServer(s *grpc.Server, srv ProcessWriteAPIServer)

Types

type Entity 

type Entity struct {
	Id          string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version     string              `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Transaction string              `protobuf:"bytes,4,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Data        map[string]*any.Any `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetData 

func (x *Entity) GetData() map[string]*any.Any

func (*Entity) GetId 

func (x *Entity) GetId() string

func (*Entity) GetName 

func (x *Entity) GetName() string

func (*Entity) GetTransaction 

func (x *Entity) GetTransaction() string

func (*Entity) GetVersion 

func (x *Entity) GetVersion() string

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect added in v0.0.3 

func (x *Entity) ProtoReflect() protoreflect.Message

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type EntityReadAPIClient 

type EntityReadAPIClient interface {
	List(ctx context.Context, in *Options, opts ...grpc.CallOption) (EntityReadAPI_ListClient, error)
	Get(ctx context.Context, in *Options, opts ...grpc.CallOption) (*Entity, error)
}

EntityReadAPIClient is the client API for EntityReadAPI service.

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

func NewEntityReadAPIClient 

func NewEntityReadAPIClient(cc grpc.ClientConnInterface) EntityReadAPIClient

type EntityReadAPIServer 

type EntityReadAPIServer interface {
	List(*Options, EntityReadAPI_ListServer) error
	Get(context.Context, *Options) (*Entity, error)
}

EntityReadAPIServer is the server API for EntityReadAPI service.

type EntityReadAPI_ListClient 

type EntityReadAPI_ListClient interface {
	Recv() (*Entity, error)
	grpc.ClientStream
}

type EntityReadAPI_ListServer 

type EntityReadAPI_ListServer interface {
	Send(*Entity) error
	grpc.ServerStream
}

type EntityWriteAPIClient 

type EntityWriteAPIClient interface {
	Create(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Entity, error)
	Update(ctx context.Context, in *Entity, opts ...grpc.CallOption) (*Entity, error)
}

EntityWriteAPIClient is the client API for EntityWriteAPI service.

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

func NewEntityWriteAPIClient 

func NewEntityWriteAPIClient(cc grpc.ClientConnInterface) EntityWriteAPIClient

type EntityWriteAPIServer 

type EntityWriteAPIServer interface {
	Create(context.Context, *Entity) (*Entity, error)
	Update(context.Context, *Entity) (*Entity, error)
}

EntityWriteAPIServer is the server API for EntityWriteAPI service.

type Event 

type Event struct {
	Id          string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version     string              `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Transaction string              `protobuf:"bytes,4,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Payload     map[string]*any.Any `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetId 

func (x *Event) GetId() string

func (*Event) GetName 

func (x *Event) GetName() string

func (*Event) GetPayload 

func (x *Event) GetPayload() map[string]*any.Any

func (*Event) GetTransaction 

func (x *Event) GetTransaction() string

func (*Event) GetVersion 

func (x *Event) GetVersion() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.0.3 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventAPIClient 

type EventAPIClient interface {
	Publish(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Event, error)
}

EventAPIClient is the client API for EventAPI service.

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

func NewEventAPIClient 

func NewEventAPIClient(cc grpc.ClientConnInterface) EventAPIClient

type EventAPIServer 

type EventAPIServer interface {
	Publish(context.Context, *Event) (*Event, error)
}

EventAPIServer is the server API for EventAPI service.

type EventReadAPIClient 

type EventReadAPIClient interface {
	List(ctx context.Context, in *Options, opts ...grpc.CallOption) (EventReadAPI_ListClient, error)
	Get(ctx context.Context, in *Options, opts ...grpc.CallOption) (*Event, error)
}

EventReadAPIClient is the client API for EventReadAPI service.

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

func NewEventReadAPIClient 

func NewEventReadAPIClient(cc grpc.ClientConnInterface) EventReadAPIClient

type EventReadAPIServer 

type EventReadAPIServer interface {
	List(*Options, EventReadAPI_ListServer) error
	Get(context.Context, *Options) (*Event, error)
}

EventReadAPIServer is the server API for EventReadAPI service.

type EventReadAPI_ListClient 

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

type EventReadAPI_ListServer 

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

type EventWriteAPIClient 

type EventWriteAPIClient interface {
	Record(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Event, error)
}

EventWriteAPIClient is the client API for EventWriteAPI service.

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

func NewEventWriteAPIClient 

func NewEventWriteAPIClient(cc grpc.ClientConnInterface) EventWriteAPIClient

type EventWriteAPIServer 

type EventWriteAPIServer interface {
	Record(context.Context, *Event) (*Event, error)
}

EventWriteAPIServer is the server API for EventWriteAPI service.

type Input 

type Input struct {
	Name    string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string              `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Event   map[string]*any.Any `` /* 152-byte string literal not displayed */
	Entity  map[string]*any.Any `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Input) Descriptor deprecated 

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

Deprecated: Use Input.ProtoReflect.Descriptor instead.

func (*Input) GetEntity 

func (x *Input) GetEntity() map[string]*any.Any

func (*Input) GetEvent 

func (x *Input) GetEvent() map[string]*any.Any

func (*Input) GetName 

func (x *Input) GetName() string

func (*Input) GetVersion 

func (x *Input) GetVersion() string

func (*Input) ProtoMessage 

func (*Input) ProtoMessage()

func (*Input) ProtoReflect added in v0.0.3 

func (x *Input) ProtoReflect() protoreflect.Message

func (*Input) Reset 

func (x *Input) Reset()

func (*Input) String 

func (x *Input) String() string

type Options 

type Options struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version     string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Transaction string `protobuf:"bytes,4,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Skip        uint32 `protobuf:"varint,10,opt,name=skip,proto3" json:"skip,omitempty"`
	Limit       uint32 `protobuf:"varint,11,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*Options) Descriptor deprecated 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetId 

func (x *Options) GetId() string

func (*Options) GetLimit added in v0.0.3 

func (x *Options) GetLimit() uint32

func (*Options) GetName 

func (x *Options) GetName() string

func (*Options) GetSkip added in v0.0.3 

func (x *Options) GetSkip() uint32

func (*Options) GetTransaction 

func (x *Options) GetTransaction() string

func (*Options) GetVersion 

func (x *Options) GetVersion() string

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect added in v0.0.3 

func (x *Options) ProtoReflect() protoreflect.Message

func (*Options) Reset 

func (x *Options) Reset()

func (*Options) String 

func (x *Options) String() string

type Output 

type Output struct {
	Id     string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Event  map[string]*any.Any `` /* 152-byte string literal not displayed */
	Entity map[string]*any.Any `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetEntity 

func (x *Output) GetEntity() map[string]*any.Any

func (*Output) GetEvent 

func (x *Output) GetEvent() map[string]*any.Any

func (*Output) GetId 

func (x *Output) GetId() string

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect added in v0.0.3 

func (x *Output) ProtoReflect() protoreflect.Message

func (*Output) Reset 

func (x *Output) Reset()

func (*Output) String 

func (x *Output) String() string

type Process 

type Process struct {
	Id          string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version     string              `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Transaction string              `protobuf:"bytes,4,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Definition  *Process_Definition `protobuf:"bytes,10,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetDefinition 

func (x *Process) GetDefinition() *Process_Definition

func (*Process) GetId 

func (x *Process) GetId() string

func (*Process) GetName 

func (x *Process) GetName() string

func (*Process) GetTransaction 

func (x *Process) GetTransaction() string

func (*Process) GetVersion 

func (x *Process) GetVersion() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect added in v0.0.3 

func (x *Process) ProtoReflect() protoreflect.Message

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type ProcessAPIClient 

type ProcessAPIClient interface {
	Execute(ctx context.Context, opts ...grpc.CallOption) (ProcessAPI_ExecuteClient, error)
}

ProcessAPIClient is the client API for ProcessAPI service.

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

func NewProcessAPIClient 

func NewProcessAPIClient(cc grpc.ClientConnInterface) ProcessAPIClient

type ProcessAPIServer 

type ProcessAPIServer interface {
	Execute(ProcessAPI_ExecuteServer) error
}

ProcessAPIServer is the server API for ProcessAPI service.

type ProcessAPI_ExecuteClient 

type ProcessAPI_ExecuteClient interface {
	Send(*Input) error
	Recv() (*Output, error)
	grpc.ClientStream
}

type ProcessAPI_ExecuteServer 

type ProcessAPI_ExecuteServer interface {
	Send(*Output) error
	Recv() (*Input, error)
	grpc.ServerStream
}

type ProcessReadAPIClient 

type ProcessReadAPIClient interface {
	List(ctx context.Context, in *Options, opts ...grpc.CallOption) (ProcessReadAPI_ListClient, error)
	Success(ctx context.Context, in *Options, opts ...grpc.CallOption) (ProcessReadAPI_SuccessClient, error)
	Failure(ctx context.Context, in *Options, opts ...grpc.CallOption) (ProcessReadAPI_FailureClient, error)
	Get(ctx context.Context, in *Options, opts ...grpc.CallOption) (*Process, error)
}

ProcessReadAPIClient is the client API for ProcessReadAPI service.

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

func NewProcessReadAPIClient 

func NewProcessReadAPIClient(cc grpc.ClientConnInterface) ProcessReadAPIClient

type ProcessReadAPIServer 

type ProcessReadAPIServer interface {
	List(*Options, ProcessReadAPI_ListServer) error
	Success(*Options, ProcessReadAPI_SuccessServer) error
	Failure(*Options, ProcessReadAPI_FailureServer) error
	Get(context.Context, *Options) (*Process, error)
}

ProcessReadAPIServer is the server API for ProcessReadAPI service.

type ProcessReadAPI_FailureClient 

type ProcessReadAPI_FailureClient interface {
	Recv() (*Process, error)
	grpc.ClientStream
}

type ProcessReadAPI_FailureServer 

type ProcessReadAPI_FailureServer interface {
	Send(*Process) error
	grpc.ServerStream
}

type ProcessReadAPI_ListClient 

type ProcessReadAPI_ListClient interface {
	Recv() (*Process, error)
	grpc.ClientStream
}

type ProcessReadAPI_ListServer 

type ProcessReadAPI_ListServer interface {
	Send(*Process) error
	grpc.ServerStream
}

type ProcessReadAPI_SuccessClient 

type ProcessReadAPI_SuccessClient interface {
	Recv() (*Process, error)
	grpc.ClientStream
}

type ProcessReadAPI_SuccessServer 

type ProcessReadAPI_SuccessServer interface {
	Send(*Process) error
	grpc.ServerStream
}

type ProcessWriteAPIClient 

type ProcessWriteAPIClient interface {
	Record(ctx context.Context, in *Process, opts ...grpc.CallOption) (*Process, error)
}

ProcessWriteAPIClient is the client API for ProcessWriteAPI service.

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

func NewProcessWriteAPIClient 

func NewProcessWriteAPIClient(cc grpc.ClientConnInterface) ProcessWriteAPIClient

type ProcessWriteAPIServer 

type ProcessWriteAPIServer interface {
	Record(context.Context, *Process) (*Process, error)
}

ProcessWriteAPIServer is the server API for ProcessWriteAPI service.

type Process_Data 

type Process_Data struct {
	Event  *Event  `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Entity *Entity `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// contains filtered or unexported fields
}

func (*Process_Data) Descriptor deprecated 

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

Deprecated: Use Process_Data.ProtoReflect.Descriptor instead.

func (*Process_Data) GetEntity 

func (x *Process_Data) GetEntity() *Entity

func (*Process_Data) GetEvent 

func (x *Process_Data) GetEvent() *Event

func (*Process_Data) ProtoMessage 

func (*Process_Data) ProtoMessage()

func (*Process_Data) ProtoReflect added in v0.0.3 

func (x *Process_Data) ProtoReflect() protoreflect.Message

func (*Process_Data) Reset 

func (x *Process_Data) Reset()

func (*Process_Data) String 

func (x *Process_Data) String() string

type Process_Definition 

type Process_Definition struct {
	Input  *Process_Data `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	Output *Process_Data `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Error  *Process_Data `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*Process_Definition) Descriptor deprecated 

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

Deprecated: Use Process_Definition.ProtoReflect.Descriptor instead.

func (*Process_Definition) GetError 

func (x *Process_Definition) GetError() *Process_Data

func (*Process_Definition) GetInput 

func (x *Process_Definition) GetInput() *Process_Data

func (*Process_Definition) GetOutput 

func (x *Process_Definition) GetOutput() *Process_Data

func (*Process_Definition) ProtoMessage 

func (*Process_Definition) ProtoMessage()

func (*Process_Definition) ProtoReflect added in v0.0.3 

func (x *Process_Definition) ProtoReflect() protoreflect.Message

func (*Process_Definition) Reset 

func (x *Process_Definition) Reset()

func (*Process_Definition) String 

func (x *Process_Definition) String() string

type UnimplementedEntityReadAPIServer 

type UnimplementedEntityReadAPIServer struct {
}

UnimplementedEntityReadAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntityReadAPIServer) Get 

func (*UnimplementedEntityReadAPIServer) Get(context.Context, *Options) (*Entity, error)

func (*UnimplementedEntityReadAPIServer) List 

func (*UnimplementedEntityReadAPIServer) List(*Options, EntityReadAPI_ListServer) error

type UnimplementedEntityWriteAPIServer 

type UnimplementedEntityWriteAPIServer struct {
}

UnimplementedEntityWriteAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntityWriteAPIServer) Create 

func (*UnimplementedEntityWriteAPIServer) Create(context.Context, *Entity) (*Entity, error)

func (*UnimplementedEntityWriteAPIServer) Update 

func (*UnimplementedEntityWriteAPIServer) Update(context.Context, *Entity) (*Entity, error)

type UnimplementedEventAPIServer 

type UnimplementedEventAPIServer struct {
}

UnimplementedEventAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventAPIServer) Publish 

func (*UnimplementedEventAPIServer) Publish(context.Context, *Event) (*Event, error)

type UnimplementedEventReadAPIServer 

type UnimplementedEventReadAPIServer struct {
}

UnimplementedEventReadAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventReadAPIServer) Get 

func (*UnimplementedEventReadAPIServer) Get(context.Context, *Options) (*Event, error)

func (*UnimplementedEventReadAPIServer) List 

func (*UnimplementedEventReadAPIServer) List(*Options, EventReadAPI_ListServer) error

type UnimplementedEventWriteAPIServer 

type UnimplementedEventWriteAPIServer struct {
}

UnimplementedEventWriteAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventWriteAPIServer) Record 

func (*UnimplementedEventWriteAPIServer) Record(context.Context, *Event) (*Event, error)

type UnimplementedProcessAPIServer 

type UnimplementedProcessAPIServer struct {
}

UnimplementedProcessAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessAPIServer) Execute 

func (*UnimplementedProcessAPIServer) Execute(ProcessAPI_ExecuteServer) error

type UnimplementedProcessReadAPIServer 

type UnimplementedProcessReadAPIServer struct {
}

UnimplementedProcessReadAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessReadAPIServer) Failure 

func (*UnimplementedProcessReadAPIServer) Failure(*Options, ProcessReadAPI_FailureServer) error

func (*UnimplementedProcessReadAPIServer) Get 

func (*UnimplementedProcessReadAPIServer) Get(context.Context, *Options) (*Process, error)

func (*UnimplementedProcessReadAPIServer) List 

func (*UnimplementedProcessReadAPIServer) List(*Options, ProcessReadAPI_ListServer) error

func (*UnimplementedProcessReadAPIServer) Success 

func (*UnimplementedProcessReadAPIServer) Success(*Options, ProcessReadAPI_SuccessServer) error

type UnimplementedProcessWriteAPIServer 

type UnimplementedProcessWriteAPIServer struct {
}

UnimplementedProcessWriteAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessWriteAPIServer) Record 

func (*UnimplementedProcessWriteAPIServer) Record(context.Context, *Process) (*Process, error)

Source Files

View all Source files

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.