shared

Documentation

Overview

Package shared is a generated protocol buffer package.

It is generated from these files:
	protos.proto

It has these top-level messages:
	Unit
	HelloRequest
	HelloResponse
	AddRequest
	AddResponse

Package shared is a generated protocol buffer package.

It is generated from these files:

protos.proto

It has these top-level messages:

Unit
HelloRequest
HelloResponse
AddRequest
AddResponse

Index

• Variables
• func HelloFactory(factory func() Hello)
• type AddRequest
  • func (*AddRequest) Descriptor() ([]byte, []int)
  • func (this *AddRequest) Equal(that interface{}) bool
  • func (this *AddRequest) GoString() string
  • func (m *AddRequest) Marshal() (dAtA []byte, err error)
  • func (m *AddRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*AddRequest) ProtoMessage()
  • func (m *AddRequest) Reset()
  • func (m *AddRequest) Size() (n int)
  • func (this *AddRequest) String() string
  • func (m *AddRequest) Unmarshal(dAtA []byte) error
• type AddResponse
  • func (*AddResponse) Descriptor() ([]byte, []int)
  • func (this *AddResponse) Equal(that interface{}) bool
  • func (this *AddResponse) GoString() string
  • func (m *AddResponse) Marshal() (dAtA []byte, err error)
  • func (m *AddResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*AddResponse) ProtoMessage()
  • func (m *AddResponse) Reset()
  • func (m *AddResponse) Size() (n int)
  • func (this *AddResponse) String() string
  • func (m *AddResponse) Unmarshal(dAtA []byte) error
• type Hello
• type HelloActor
  • func (a *HelloActor) Receive(ctx actor.Context)
• type HelloGrain
  • func GetHelloGrain(id string) *HelloGrain
  • func (g *HelloGrain) Add(r *AddRequest, options ...cluster.GrainCallOption) (*AddResponse, error)
  • func (g *HelloGrain) AddChan(r *AddRequest, options ...cluster.GrainCallOption) (<-chan *AddResponse, <-chan error)
  • func (g *HelloGrain) SayHello(r *HelloRequest, options ...cluster.GrainCallOption) (*HelloResponse, error)
  • func (g *HelloGrain) SayHelloChan(r *HelloRequest, options ...cluster.GrainCallOption) (<-chan *HelloResponse, <-chan error)
  • func (g *HelloGrain) VoidFunc(r *AddRequest, options ...cluster.GrainCallOption) (*Unit, error)
  • func (g *HelloGrain) VoidFuncChan(r *AddRequest, options ...cluster.GrainCallOption) (<-chan *Unit, <-chan error)
• type HelloRequest
  • func (*HelloRequest) Descriptor() ([]byte, []int)
  • func (this *HelloRequest) Equal(that interface{}) bool
  • func (this *HelloRequest) GoString() string
  • func (m *HelloRequest) Marshal() (dAtA []byte, err error)
  • func (m *HelloRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*HelloRequest) ProtoMessage()
  • func (m *HelloRequest) Reset()
  • func (m *HelloRequest) Size() (n int)
  • func (this *HelloRequest) String() string
  • func (m *HelloRequest) Unmarshal(dAtA []byte) error
• type HelloResponse
  • func (*HelloResponse) Descriptor() ([]byte, []int)
  • func (this *HelloResponse) Equal(that interface{}) bool
  • func (this *HelloResponse) GoString() string
  • func (m *HelloResponse) Marshal() (dAtA []byte, err error)
  • func (m *HelloResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*HelloResponse) ProtoMessage()
  • func (m *HelloResponse) Reset()
  • func (m *HelloResponse) Size() (n int)
  • func (this *HelloResponse) String() string
  • func (m *HelloResponse) Unmarshal(dAtA []byte) error
• type Unit
  • func (*Unit) Descriptor() ([]byte, []int)
  • func (this *Unit) Equal(that interface{}) bool
  • func (this *Unit) GoString() string
  • func (m *Unit) Marshal() (dAtA []byte, err error)
  • func (m *Unit) MarshalTo(dAtA []byte) (int, error)
  • func (*Unit) ProtoMessage()
  • func (m *Unit) Reset()
  • func (m *Unit) Size() (n int)
  • func (this *Unit) String() string
  • func (m *Unit) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtos   = fmt.Errorf("proto: integer overflow")
)

Functions

func HelloFactory

func HelloFactory(factory func() Hello)

Types

type AddRequest

type AddRequest struct {
	A float64 `protobuf:"fixed64,1,opt,name=a,proto3" json:"a,omitempty"`
	B float64 `protobuf:"fixed64,2,opt,name=b,proto3" json:"b,omitempty"`
}

func (*AddRequest) Descriptor

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

func (*AddRequest) Equal

func (this *AddRequest) Equal(that interface{}) bool

func (*AddRequest) GoString

func (this *AddRequest) GoString() string

func (*AddRequest) Marshal

func (m *AddRequest) Marshal() (dAtA []byte, err error)

func (*AddRequest) MarshalTo

func (m *AddRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddRequest) ProtoMessage

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset

func (m *AddRequest) Reset()

func (*AddRequest) Size

func (m *AddRequest) Size() (n int)

func (*AddRequest) String

func (this *AddRequest) String() string

func (*AddRequest) Unmarshal

func (m *AddRequest) Unmarshal(dAtA []byte) error

type AddResponse

type AddResponse struct {
	Result float64 `protobuf:"fixed64,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*AddResponse) Descriptor

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

func (*AddResponse) Equal

func (this *AddResponse) Equal(that interface{}) bool

func (*AddResponse) GoString

func (this *AddResponse) GoString() string

func (*AddResponse) Marshal

func (m *AddResponse) Marshal() (dAtA []byte, err error)

func (*AddResponse) MarshalTo

func (m *AddResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddResponse) ProtoMessage

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset

func (m *AddResponse) Reset()

func (*AddResponse) Size

func (m *AddResponse) Size() (n int)

func (*AddResponse) String

func (this *AddResponse) String() string

func (*AddResponse) Unmarshal

func (m *AddResponse) Unmarshal(dAtA []byte) error

type Hello

type Hello interface {
	Init(id string)

	SayHello(*HelloRequest) (*HelloResponse, error)

	Add(*AddRequest) (*AddResponse, error)

	VoidFunc(*AddRequest) (*Unit, error)
}

type HelloActor

type HelloActor struct {
	// contains filtered or unexported fields
}

func (*HelloActor) Receive

func (a *HelloActor) Receive(ctx actor.Context)

type HelloGrain

type HelloGrain struct {
	ID string
}

func GetHelloGrain

func GetHelloGrain(id string) *HelloGrain

func (*HelloGrain) Add

func (g *HelloGrain) Add(r *AddRequest, options ...cluster.GrainCallOption) (*AddResponse, error)

func (*HelloGrain) AddChan

func (g *HelloGrain) AddChan(r *AddRequest, options ...cluster.GrainCallOption) (<-chan *AddResponse, <-chan error)

func (*HelloGrain) SayHello

func (g *HelloGrain) SayHello(r *HelloRequest, options ...cluster.GrainCallOption) (*HelloResponse, error)

func (*HelloGrain) SayHelloChan

func (g *HelloGrain) SayHelloChan(r *HelloRequest, options ...cluster.GrainCallOption) (<-chan *HelloResponse, <-chan error)

func (*HelloGrain) VoidFunc

func (g *HelloGrain) VoidFunc(r *AddRequest, options ...cluster.GrainCallOption) (*Unit, error)

func (*HelloGrain) VoidFuncChan

func (g *HelloGrain) VoidFuncChan(r *AddRequest, options ...cluster.GrainCallOption) (<-chan *Unit, <-chan error)

type HelloRequest

type HelloRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*HelloRequest) Descriptor

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

func (*HelloRequest) Equal

func (this *HelloRequest) Equal(that interface{}) bool

func (*HelloRequest) GoString

func (this *HelloRequest) GoString() string

func (*HelloRequest) Marshal

func (m *HelloRequest) Marshal() (dAtA []byte, err error)

func (*HelloRequest) MarshalTo

func (m *HelloRequest) MarshalTo(dAtA []byte) (int, error)

func (*HelloRequest) ProtoMessage

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset

func (m *HelloRequest) Reset()

func (*HelloRequest) Size

func (m *HelloRequest) Size() (n int)

func (*HelloRequest) String

func (this *HelloRequest) String() string

func (*HelloRequest) Unmarshal

func (m *HelloRequest) Unmarshal(dAtA []byte) error

type HelloResponse

type HelloResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*HelloResponse) Descriptor

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

func (*HelloResponse) Equal

func (this *HelloResponse) Equal(that interface{}) bool

func (*HelloResponse) GoString

func (this *HelloResponse) GoString() string

func (*HelloResponse) Marshal

func (m *HelloResponse) Marshal() (dAtA []byte, err error)

func (*HelloResponse) MarshalTo

func (m *HelloResponse) MarshalTo(dAtA []byte) (int, error)

func (*HelloResponse) ProtoMessage

func (*HelloResponse) ProtoMessage()

func (*HelloResponse) Reset

func (m *HelloResponse) Reset()

func (*HelloResponse) Size

func (m *HelloResponse) Size() (n int)

func (*HelloResponse) String

func (this *HelloResponse) String() string

func (*HelloResponse) Unmarshal

func (m *HelloResponse) Unmarshal(dAtA []byte) error

type Unit

type Unit struct {
}

func (*Unit) Descriptor

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

func (*Unit) Equal

func (this *Unit) Equal(that interface{}) bool

func (*Unit) GoString

func (this *Unit) GoString() string

func (*Unit) Marshal

func (m *Unit) Marshal() (dAtA []byte, err error)

func (*Unit) MarshalTo

func (m *Unit) MarshalTo(dAtA []byte) (int, error)

func (*Unit) ProtoMessage

func (*Unit) ProtoMessage()

func (*Unit) Reset

func (m *Unit) Reset()

func (*Unit) Size

func (m *Unit) Size() (n int)

func (*Unit) String

func (this *Unit) String() string

func (*Unit) Unmarshal

func (m *Unit) Unmarshal(dAtA []byte) error