daprinternal

package
v0.6.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDaprInternalServer 

func RegisterDaprInternalServer(s *grpc.Server, srv DaprInternalServer)

func RegisterPlacementServiceServer 

func RegisterPlacementServiceServer(s *grpc.Server, srv PlacementServiceServer)

Types

type CallActorEnvelope 

type CallActorEnvelope struct {
	ActorID              string            `protobuf:"bytes,1,opt,name=actorID,proto3" json:"actorID,omitempty"`
	ActorType            string            `protobuf:"bytes,2,opt,name=actorType,proto3" json:"actorType,omitempty"`
	Method               string            `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Data                 *any.Any          `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CallActorEnvelope) Descriptor 

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

func (*CallActorEnvelope) GetActorID 

func (m *CallActorEnvelope) GetActorID() string

func (*CallActorEnvelope) GetActorType 

func (m *CallActorEnvelope) GetActorType() string

func (*CallActorEnvelope) GetData 

func (m *CallActorEnvelope) GetData() *any.Any

func (*CallActorEnvelope) GetMetadata added in v0.2.0 

func (m *CallActorEnvelope) GetMetadata() map[string]string

func (*CallActorEnvelope) GetMethod 

func (m *CallActorEnvelope) GetMethod() string

func (*CallActorEnvelope) ProtoMessage 

func (*CallActorEnvelope) ProtoMessage()

func (*CallActorEnvelope) Reset 

func (m *CallActorEnvelope) Reset()

func (*CallActorEnvelope) String 

func (m *CallActorEnvelope) String() string

func (*CallActorEnvelope) XXX_DiscardUnknown 

func (m *CallActorEnvelope) XXX_DiscardUnknown()

func (*CallActorEnvelope) XXX_Marshal 

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

func (*CallActorEnvelope) XXX_Merge 

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

func (*CallActorEnvelope) XXX_Size 

func (m *CallActorEnvelope) XXX_Size() int

func (*CallActorEnvelope) XXX_Unmarshal 

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

type DaprInternalClient 

type DaprInternalClient interface {
	CallActor(ctx context.Context, in *CallActorEnvelope, opts ...grpc.CallOption) (*InvokeResponse, error)
	CallLocal(ctx context.Context, in *LocalCallEnvelope, opts ...grpc.CallOption) (*InvokeResponse, error)
}

DaprInternalClient is the client API for DaprInternal service.

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

func NewDaprInternalClient 

func NewDaprInternalClient(cc *grpc.ClientConn) DaprInternalClient

type DaprInternalServer 

type DaprInternalServer interface {
	CallActor(context.Context, *CallActorEnvelope) (*InvokeResponse, error)
	CallLocal(context.Context, *LocalCallEnvelope) (*InvokeResponse, error)
}

DaprInternalServer is the server API for DaprInternal service.

type GetStateEnvelope 

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

func (*GetStateEnvelope) Descriptor 

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

func (*GetStateEnvelope) GetKey 

func (m *GetStateEnvelope) GetKey() string

func (*GetStateEnvelope) ProtoMessage 

func (*GetStateEnvelope) ProtoMessage()

func (*GetStateEnvelope) Reset 

func (m *GetStateEnvelope) Reset()

func (*GetStateEnvelope) String 

func (m *GetStateEnvelope) String() string

func (*GetStateEnvelope) XXX_DiscardUnknown 

func (m *GetStateEnvelope) XXX_DiscardUnknown()

func (*GetStateEnvelope) XXX_Marshal 

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

func (*GetStateEnvelope) XXX_Merge 

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

func (*GetStateEnvelope) XXX_Size 

func (m *GetStateEnvelope) XXX_Size() int

func (*GetStateEnvelope) XXX_Unmarshal 

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

type Host 

type Host struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Port                 int64    `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Load                 int64    `protobuf:"varint,3,opt,name=load,proto3" json:"load,omitempty"`
	Entities             []string `protobuf:"bytes,4,rep,name=entities,proto3" json:"entities,omitempty"`
	Id                   string   `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Host) Descriptor 

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

func (*Host) GetEntities 

func (m *Host) GetEntities() []string

func (*Host) GetId added in v0.4.0 

func (m *Host) GetId() string

func (*Host) GetLoad 

func (m *Host) GetLoad() int64

func (*Host) GetName 

func (m *Host) GetName() string

func (*Host) GetPort 

func (m *Host) GetPort() int64

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) Reset 

func (m *Host) Reset()

func (*Host) String 

func (m *Host) String() string

func (*Host) XXX_DiscardUnknown 

func (m *Host) XXX_DiscardUnknown()

func (*Host) XXX_Marshal 

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

func (*Host) XXX_Merge 

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

func (*Host) XXX_Size 

func (m *Host) XXX_Size() int

func (*Host) XXX_Unmarshal 

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

type InvokeResponse 

type InvokeResponse struct {
	Data                 *any.Any          `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*InvokeResponse) Descriptor 

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

func (*InvokeResponse) GetData 

func (m *InvokeResponse) GetData() *any.Any

func (*InvokeResponse) GetMetadata 

func (m *InvokeResponse) GetMetadata() map[string]string

func (*InvokeResponse) ProtoMessage 

func (*InvokeResponse) ProtoMessage()

func (*InvokeResponse) Reset 

func (m *InvokeResponse) Reset()

func (*InvokeResponse) String 

func (m *InvokeResponse) String() string

func (*InvokeResponse) XXX_DiscardUnknown 

func (m *InvokeResponse) XXX_DiscardUnknown()

func (*InvokeResponse) XXX_Marshal 

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

func (*InvokeResponse) XXX_Merge 

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

func (*InvokeResponse) XXX_Size 

func (m *InvokeResponse) XXX_Size() int

func (*InvokeResponse) XXX_Unmarshal 

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

type KeyVal 

type KeyVal struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *any.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyVal) Descriptor 

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

func (*KeyVal) GetKey 

func (m *KeyVal) GetKey() string

func (*KeyVal) GetValue 

func (m *KeyVal) GetValue() *any.Any

func (*KeyVal) ProtoMessage 

func (*KeyVal) ProtoMessage()

func (*KeyVal) Reset 

func (m *KeyVal) Reset()

func (*KeyVal) String 

func (m *KeyVal) String() string

func (*KeyVal) XXX_DiscardUnknown 

func (m *KeyVal) XXX_DiscardUnknown()

func (*KeyVal) XXX_Marshal 

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

func (*KeyVal) XXX_Merge 

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

func (*KeyVal) XXX_Size 

func (m *KeyVal) XXX_Size() int

func (*KeyVal) XXX_Unmarshal 

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

type LocalCallEnvelope 

type LocalCallEnvelope struct {
	Data                 *any.Any          `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Method               string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*LocalCallEnvelope) Descriptor 

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

func (*LocalCallEnvelope) GetData 

func (m *LocalCallEnvelope) GetData() *any.Any

func (*LocalCallEnvelope) GetMetadata 

func (m *LocalCallEnvelope) GetMetadata() map[string]string

func (*LocalCallEnvelope) GetMethod 

func (m *LocalCallEnvelope) GetMethod() string

func (*LocalCallEnvelope) ProtoMessage 

func (*LocalCallEnvelope) ProtoMessage()

func (*LocalCallEnvelope) Reset 

func (m *LocalCallEnvelope) Reset()

func (*LocalCallEnvelope) String 

func (m *LocalCallEnvelope) String() string

func (*LocalCallEnvelope) XXX_DiscardUnknown 

func (m *LocalCallEnvelope) XXX_DiscardUnknown()

func (*LocalCallEnvelope) XXX_Marshal 

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

func (*LocalCallEnvelope) XXX_Merge 

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

func (*LocalCallEnvelope) XXX_Size 

func (m *LocalCallEnvelope) XXX_Size() int

func (*LocalCallEnvelope) XXX_Unmarshal 

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

type PlacementOrder 

type PlacementOrder struct {
	Tables               *PlacementTables `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	Operation            string           `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PlacementOrder) Descriptor 

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

func (*PlacementOrder) GetOperation 

func (m *PlacementOrder) GetOperation() string

func (*PlacementOrder) GetTables 

func (m *PlacementOrder) GetTables() *PlacementTables

func (*PlacementOrder) ProtoMessage 

func (*PlacementOrder) ProtoMessage()

func (*PlacementOrder) Reset 

func (m *PlacementOrder) Reset()

func (*PlacementOrder) String 

func (m *PlacementOrder) String() string

func (*PlacementOrder) XXX_DiscardUnknown 

func (m *PlacementOrder) XXX_DiscardUnknown()

func (*PlacementOrder) XXX_Marshal 

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

func (*PlacementOrder) XXX_Merge 

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

func (*PlacementOrder) XXX_Size 

func (m *PlacementOrder) XXX_Size() int

func (*PlacementOrder) XXX_Unmarshal 

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

type PlacementServiceClient 

type PlacementServiceClient interface {
	ReportDaprStatus(ctx context.Context, opts ...grpc.CallOption) (PlacementService_ReportDaprStatusClient, error)
}

PlacementServiceClient is the client API for PlacementService service.

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

func NewPlacementServiceClient 

func NewPlacementServiceClient(cc *grpc.ClientConn) PlacementServiceClient

type PlacementServiceServer 

type PlacementServiceServer interface {
	ReportDaprStatus(PlacementService_ReportDaprStatusServer) error
}

PlacementServiceServer is the server API for PlacementService service.

type PlacementService_ReportDaprStatusClient 

type PlacementService_ReportDaprStatusClient interface {
	Send(*Host) error
	Recv() (*PlacementOrder, error)
	grpc.ClientStream
}

type PlacementService_ReportDaprStatusServer 

type PlacementService_ReportDaprStatusServer interface {
	Send(*PlacementOrder) error
	Recv() (*Host, error)
	grpc.ServerStream
}

type PlacementTable 

type PlacementTable struct {
	Hosts                map[uint64]string `` /* 152-byte string literal not displayed */
	SortedSet            []uint64          `protobuf:"varint,2,rep,packed,name=sortedSet,proto3" json:"sortedSet,omitempty"`
	LoadMap              map[string]*Host  `` /* 155-byte string literal not displayed */
	TotalLoad            int64             `protobuf:"varint,4,opt,name=totalLoad,proto3" json:"totalLoad,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PlacementTable) Descriptor 

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

func (*PlacementTable) GetHosts 

func (m *PlacementTable) GetHosts() map[uint64]string

func (*PlacementTable) GetLoadMap 

func (m *PlacementTable) GetLoadMap() map[string]*Host

func (*PlacementTable) GetSortedSet 

func (m *PlacementTable) GetSortedSet() []uint64

func (*PlacementTable) GetTotalLoad 

func (m *PlacementTable) GetTotalLoad() int64

func (*PlacementTable) ProtoMessage 

func (*PlacementTable) ProtoMessage()

func (*PlacementTable) Reset 

func (m *PlacementTable) Reset()

func (*PlacementTable) String 

func (m *PlacementTable) String() string

func (*PlacementTable) XXX_DiscardUnknown 

func (m *PlacementTable) XXX_DiscardUnknown()

func (*PlacementTable) XXX_Marshal 

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

func (*PlacementTable) XXX_Merge 

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

func (*PlacementTable) XXX_Size 

func (m *PlacementTable) XXX_Size() int

func (*PlacementTable) XXX_Unmarshal 

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

type PlacementTables 

type PlacementTables struct {
	Entries              map[string]*PlacementTable `` /* 155-byte string literal not displayed */
	Version              string                     `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*PlacementTables) Descriptor 

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

func (*PlacementTables) GetEntries 

func (m *PlacementTables) GetEntries() map[string]*PlacementTable

func (*PlacementTables) GetVersion 

func (m *PlacementTables) GetVersion() string

func (*PlacementTables) ProtoMessage 

func (*PlacementTables) ProtoMessage()

func (*PlacementTables) Reset 

func (m *PlacementTables) Reset()

func (*PlacementTables) String 

func (m *PlacementTables) String() string

func (*PlacementTables) XXX_DiscardUnknown 

func (m *PlacementTables) XXX_DiscardUnknown()

func (*PlacementTables) XXX_Marshal 

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

func (*PlacementTables) XXX_Merge 

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

func (*PlacementTables) XXX_Size 

func (m *PlacementTables) XXX_Size() int

func (*PlacementTables) XXX_Unmarshal 

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

type SaveStateEnvelope 

type SaveStateEnvelope struct {
	State                []*KeyVal `protobuf:"bytes,1,rep,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SaveStateEnvelope) Descriptor 

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

func (*SaveStateEnvelope) GetState 

func (m *SaveStateEnvelope) GetState() []*KeyVal

func (*SaveStateEnvelope) ProtoMessage 

func (*SaveStateEnvelope) ProtoMessage()

func (*SaveStateEnvelope) Reset 

func (m *SaveStateEnvelope) Reset()

func (*SaveStateEnvelope) String 

func (m *SaveStateEnvelope) String() string

func (*SaveStateEnvelope) XXX_DiscardUnknown 

func (m *SaveStateEnvelope) XXX_DiscardUnknown()

func (*SaveStateEnvelope) XXX_Marshal 

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

func (*SaveStateEnvelope) XXX_Merge 

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

func (*SaveStateEnvelope) XXX_Size 

func (m *SaveStateEnvelope) XXX_Size() int

func (*SaveStateEnvelope) XXX_Unmarshal 

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

type UnimplementedDaprInternalServer added in v0.2.0 

type UnimplementedDaprInternalServer struct {
}

UnimplementedDaprInternalServer can be embedded to have forward compatible implementations.

func (*UnimplementedDaprInternalServer) CallActor added in v0.2.0 

func (*UnimplementedDaprInternalServer) CallActor(ctx context.Context, req *CallActorEnvelope) (*InvokeResponse, error)

func (*UnimplementedDaprInternalServer) CallLocal added in v0.2.0 

func (*UnimplementedDaprInternalServer) CallLocal(ctx context.Context, req *LocalCallEnvelope) (*InvokeResponse, error)

type UnimplementedPlacementServiceServer added in v0.2.0 

type UnimplementedPlacementServiceServer struct {
}

UnimplementedPlacementServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlacementServiceServer) ReportDaprStatus added in v0.2.0 

func (*UnimplementedPlacementServiceServer) ReportDaprStatus(srv PlacementService_ReportDaprStatusServer) 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.