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: 11 Imported by: 2

README

Phi Suite Data.go

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

Overview

This project contains the Go module to create the Data API server & client.
For more details, see Phi Suite Data.

Installation

go get github.com/phisuite/data.go

Creating the server

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

type eventAPIServer struct { ... }

func (s *eventAPIServer) Publish(ctx context.Context, req *data.Event) (*data.Event, error) {
    ... 
}

lis, err := net.Listen("tcp", ":50051")
grpcServer := grpc.NewServer()
data.RegisterEventAPIServer(grpcServer, &eventAPIServer{})
grpcServer.Serve(lis)

For more details, see gRPC Basics - Go: Creating the server.

Creating the client

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

conn, err := grpc.Dial(*serverAddr)
defer conn.Close()

client := data.NewEventAPIClient(conn)
event := client.Publish(context.Background(), &data.Event{ ... })

For more details, see gRPC Basics - Go: Creating the client.

Documentation

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 RegisterEntityReadAPIServer added in v0.0.2 

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

func RegisterEntityWriteAPIServer added in v0.0.2 

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

func RegisterEventAPIServer 

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

func RegisterEventReadAPIServer added in v0.0.2 

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

func RegisterEventWriteAPIServer added in v0.0.2 

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

func RegisterProcessAPIServer 

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

func RegisterProcessReadAPIServer added in v0.0.2 

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

func RegisterProcessWriteAPIServer added in v0.0.2 

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 added in v0.0.2 

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 added in v0.0.2 

func NewEntityReadAPIClient(cc grpc.ClientConnInterface) EntityReadAPIClient

type EntityReadAPIServer added in v0.0.2 

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 added in v0.0.2 

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

type EntityReadAPI_ListServer added in v0.0.2 

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

type EntityWriteAPIClient added in v0.0.2 

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 added in v0.0.2 

func NewEntityWriteAPIClient(cc grpc.ClientConnInterface) EntityWriteAPIClient

type EntityWriteAPIServer added in v0.0.2 

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 added in v0.0.2 

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 added in v0.0.2 

func NewEventReadAPIClient(cc grpc.ClientConnInterface) EventReadAPIClient

type EventReadAPIServer added in v0.0.2 

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 added in v0.0.2 

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

type EventReadAPI_ListServer added in v0.0.2 

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

type EventWriteAPIClient added in v0.0.2 

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 added in v0.0.2 

func NewEventWriteAPIClient(cc grpc.ClientConnInterface) EventWriteAPIClient

type EventWriteAPIServer added in v0.0.2 

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

EventWriteAPIServer is the server API for EventWriteAPI service.

type Input added in v0.0.2 

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 added in v0.0.2 

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

Deprecated: Use Input.ProtoReflect.Descriptor instead.

func (*Input) GetEntity added in v0.0.2 

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

func (*Input) GetEvent added in v0.0.2 

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

func (*Input) GetName added in v0.0.2 

func (x *Input) GetName() string

func (*Input) GetVersion added in v0.0.2 

func (x *Input) GetVersion() string

func (*Input) ProtoMessage added in v0.0.2 

func (*Input) ProtoMessage()

func (*Input) ProtoReflect added in v0.0.3 

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

func (*Input) Reset added in v0.0.2 

func (x *Input) Reset()

func (*Input) String added in v0.0.2 

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 added in v0.0.2 

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 added in v0.0.2 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetEntity added in v0.0.2 

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

func (*Output) GetEvent added in v0.0.2 

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

func (*Output) GetId added in v0.0.2 

func (x *Output) GetId() string

func (*Output) ProtoMessage added in v0.0.2 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect added in v0.0.3 

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

func (*Output) Reset added in v0.0.2 

func (x *Output) Reset()

func (*Output) String added in v0.0.2 

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 added in v0.0.2 

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 added in v0.0.2 

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 added in v0.0.2 

func NewProcessReadAPIClient(cc grpc.ClientConnInterface) ProcessReadAPIClient

type ProcessReadAPIServer added in v0.0.2 

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 added in v0.0.2 

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

type ProcessReadAPI_FailureServer added in v0.0.2 

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

type ProcessReadAPI_ListClient added in v0.0.2 

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

type ProcessReadAPI_ListServer added in v0.0.2 

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

type ProcessReadAPI_SuccessClient added in v0.0.2 

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

type ProcessReadAPI_SuccessServer added in v0.0.2 

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

type ProcessWriteAPIClient added in v0.0.2 

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 added in v0.0.2 

func NewProcessWriteAPIClient(cc grpc.ClientConnInterface) ProcessWriteAPIClient

type ProcessWriteAPIServer added in v0.0.2 

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

ProcessWriteAPIServer is the server API for ProcessWriteAPI service.

type Process_Data added in v0.0.2 

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 added in v0.0.2 

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

Deprecated: Use Process_Data.ProtoReflect.Descriptor instead.

func (*Process_Data) GetEntity added in v0.0.2 

func (x *Process_Data) GetEntity() *Entity

func (*Process_Data) GetEvent added in v0.0.2 

func (x *Process_Data) GetEvent() *Event

func (*Process_Data) ProtoMessage added in v0.0.2 

func (*Process_Data) ProtoMessage()

func (*Process_Data) ProtoReflect added in v0.0.3 

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

func (*Process_Data) Reset added in v0.0.2 

func (x *Process_Data) Reset()

func (*Process_Data) String added in v0.0.2 

func (x *Process_Data) String() string

type Process_Definition added in v0.0.2 

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 added in v0.0.2 

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

Deprecated: Use Process_Definition.ProtoReflect.Descriptor instead.

func (*Process_Definition) GetError added in v0.0.2 

func (x *Process_Definition) GetError() *Process_Data

func (*Process_Definition) GetInput added in v0.0.2 

func (x *Process_Definition) GetInput() *Process_Data

func (*Process_Definition) GetOutput added in v0.0.2 

func (x *Process_Definition) GetOutput() *Process_Data

func (*Process_Definition) ProtoMessage added in v0.0.2 

func (*Process_Definition) ProtoMessage()

func (*Process_Definition) ProtoReflect added in v0.0.3 

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

func (*Process_Definition) Reset added in v0.0.2 

func (x *Process_Definition) Reset()

func (*Process_Definition) String added in v0.0.2 

func (x *Process_Definition) String() string

type UnimplementedEntityReadAPIServer added in v0.0.2 

type UnimplementedEntityReadAPIServer struct {
}

UnimplementedEntityReadAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntityReadAPIServer) Get added in v0.0.2 

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

func (*UnimplementedEntityReadAPIServer) List added in v0.0.2 

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

type UnimplementedEntityWriteAPIServer added in v0.0.2 

type UnimplementedEntityWriteAPIServer struct {
}

UnimplementedEntityWriteAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEntityWriteAPIServer) Create added in v0.0.2 

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

func (*UnimplementedEntityWriteAPIServer) Update added in v0.0.2 

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 added in v0.0.2 

type UnimplementedEventReadAPIServer struct {
}

UnimplementedEventReadAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventReadAPIServer) Get added in v0.0.2 

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

func (*UnimplementedEventReadAPIServer) List added in v0.0.2 

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

type UnimplementedEventWriteAPIServer added in v0.0.2 

type UnimplementedEventWriteAPIServer struct {
}

UnimplementedEventWriteAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventWriteAPIServer) Record added in v0.0.2 

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 added in v0.0.2 

type UnimplementedProcessReadAPIServer struct {
}

UnimplementedProcessReadAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessReadAPIServer) Failure added in v0.0.2 

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

func (*UnimplementedProcessReadAPIServer) Get added in v0.0.2 

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

func (*UnimplementedProcessReadAPIServer) List added in v0.0.2 

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

func (*UnimplementedProcessReadAPIServer) Success added in v0.0.2 

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

type UnimplementedProcessWriteAPIServer added in v0.0.2 

type UnimplementedProcessWriteAPIServer struct {
}

UnimplementedProcessWriteAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessWriteAPIServer) Record added in v0.0.2 

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.