demo

README

Demo cluster

This is a sample cluster that you can experiment with.

Documentation

Overview

Package demo contains a demo implementation of a server and client that uses the clusterfunk library.

Index

• Variables
• func RegisterDemoServiceServer(s *grpc.Server, srv DemoServiceServer)
• type DemoServiceClient
  • func NewDemoServiceClient(cc grpc.ClientConnInterface) DemoServiceClient
• type DemoServiceServer
• type LiffRequest
  • func (*LiffRequest) Descriptor() ([]byte, []int)
  • func (x *LiffRequest) GetID() int64
  • func (*LiffRequest) ProtoMessage()
  • func (x *LiffRequest) ProtoReflect() protoreflect.Message
  • func (x *LiffRequest) Reset()
  • func (x *LiffRequest) String() string
• type LiffResponse
  • func (*LiffResponse) Descriptor() ([]byte, []int)
  • func (x *LiffResponse) GetDefinition() string
  • func (x *LiffResponse) GetID() int64
  • func (x *LiffResponse) GetNodeID() string
  • func (*LiffResponse) ProtoMessage()
  • func (x *LiffResponse) ProtoReflect() protoreflect.Message
  • func (x *LiffResponse) Reset()
  • func (x *LiffResponse) String() string
• type UnimplementedDemoServiceServer
  • func (*UnimplementedDemoServiceServer) Liff(context.Context, *LiffRequest) (*LiffResponse, error)

Variables

var File_demo_proto protoreflect.FileDescriptor

Functions

func RegisterDemoServiceServer

func RegisterDemoServiceServer(s *grpc.Server, srv DemoServiceServer)

Types

type DemoServiceClient

type DemoServiceClient interface {
	// This method returns a line from one of the Liff books.
	Liff(ctx context.Context, in *LiffRequest, opts ...grpc.CallOption) (*LiffResponse, error)
}

DemoServiceClient is the client API for DemoService service.

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

func NewDemoServiceClient

func NewDemoServiceClient(cc grpc.ClientConnInterface) DemoServiceClient

type DemoServiceServer

type DemoServiceServer interface {
	// This method returns a line from one of the Liff books.
	Liff(context.Context, *LiffRequest) (*LiffResponse, error)
}

DemoServiceServer is the server API for DemoService service.

type LiffRequest

type LiffRequest struct {
	ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*LiffRequest) Descriptor

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

Deprecated: Use LiffRequest.ProtoReflect.Descriptor instead.

func (*LiffRequest) GetID

func (x *LiffRequest) GetID() int64

func (*LiffRequest) ProtoMessage

func (*LiffRequest) ProtoMessage()

func (*LiffRequest) ProtoReflect

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

func (*LiffRequest) Reset

func (x *LiffRequest) Reset()

func (*LiffRequest) String

func (x *LiffRequest) String() string

type LiffResponse

type LiffResponse struct {
	ID         int64  `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`                // This is the request ID
	Definition string `protobuf:"bytes,2,opt,name=Definition,proto3" json:"Definition,omitempty"` //
	NodeID     string `protobuf:"bytes,3,opt,name=NodeID,proto3" json:"NodeID,omitempty"`         // This is the node running the service
	// contains filtered or unexported fields
}

func (*LiffResponse) Descriptor

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

Deprecated: Use LiffResponse.ProtoReflect.Descriptor instead.

func (*LiffResponse) GetDefinition

func (x *LiffResponse) GetDefinition() string

func (*LiffResponse) GetID

func (x *LiffResponse) GetID() int64

func (*LiffResponse) GetNodeID

func (x *LiffResponse) GetNodeID() string

func (*LiffResponse) ProtoMessage

func (*LiffResponse) ProtoMessage()

func (*LiffResponse) ProtoReflect

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

func (*LiffResponse) Reset

func (x *LiffResponse) Reset()

func (*LiffResponse) String

func (x *LiffResponse) String() string

type UnimplementedDemoServiceServer

type UnimplementedDemoServiceServer struct {
}

UnimplementedDemoServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDemoServiceServer) Liff

func (*UnimplementedDemoServiceServer) Liff(context.Context, *LiffRequest) (*LiffResponse, error)