daprinternal

package
v0.4.0-rc.0 Latest Latest
Warning

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

Go to latest
Published: Feb 11, 2020 License: MIT Imports: 9 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 Component

type Component struct {
	Metadata             *ComponentMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec                 *ComponentSpec     `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Auth                 *ComponentAuth     `protobuf:"bytes,3,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Component) Descriptor

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

func (*Component) GetAuth

func (m *Component) GetAuth() *ComponentAuth

func (*Component) GetMetadata

func (m *Component) GetMetadata() *ComponentMetadata

func (*Component) GetSpec

func (m *Component) GetSpec() *ComponentSpec

func (*Component) ProtoMessage

func (*Component) ProtoMessage()

func (*Component) Reset

func (m *Component) Reset()

func (*Component) String

func (m *Component) String() string

func (*Component) XXX_DiscardUnknown

func (m *Component) XXX_DiscardUnknown()

func (*Component) XXX_Marshal

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

func (*Component) XXX_Merge

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

func (*Component) XXX_Size

func (m *Component) XXX_Size() int

func (*Component) XXX_Unmarshal

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

type ComponentAuth

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

func (*ComponentAuth) Descriptor

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

func (*ComponentAuth) GetSecretStore

func (m *ComponentAuth) GetSecretStore() string

func (*ComponentAuth) ProtoMessage

func (*ComponentAuth) ProtoMessage()

func (*ComponentAuth) Reset

func (m *ComponentAuth) Reset()

func (*ComponentAuth) String

func (m *ComponentAuth) String() string

func (*ComponentAuth) XXX_DiscardUnknown

func (m *ComponentAuth) XXX_DiscardUnknown()

func (*ComponentAuth) XXX_Marshal

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

func (*ComponentAuth) XXX_Merge

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

func (*ComponentAuth) XXX_Size

func (m *ComponentAuth) XXX_Size() int

func (*ComponentAuth) XXX_Unmarshal

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

type ComponentMetadata

type ComponentMetadata struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ComponentMetadata) Descriptor

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

func (*ComponentMetadata) GetName

func (m *ComponentMetadata) GetName() string

func (*ComponentMetadata) GetNamespace

func (m *ComponentMetadata) GetNamespace() string

func (*ComponentMetadata) ProtoMessage

func (*ComponentMetadata) ProtoMessage()

func (*ComponentMetadata) Reset

func (m *ComponentMetadata) Reset()

func (*ComponentMetadata) String

func (m *ComponentMetadata) String() string

func (*ComponentMetadata) XXX_DiscardUnknown

func (m *ComponentMetadata) XXX_DiscardUnknown()

func (*ComponentMetadata) XXX_Marshal

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

func (*ComponentMetadata) XXX_Merge

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

func (*ComponentMetadata) XXX_Size

func (m *ComponentMetadata) XXX_Size() int

func (*ComponentMetadata) XXX_Unmarshal

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

type ComponentMetadataItem

type ComponentMetadataItem struct {
	Name                 string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	SecretKeyRef         *ComponentSecretKeyRef `protobuf:"bytes,3,opt,name=secretKeyRef,proto3" json:"secretKeyRef,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ComponentMetadataItem) Descriptor

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

func (*ComponentMetadataItem) GetName

func (m *ComponentMetadataItem) GetName() string

func (*ComponentMetadataItem) GetSecretKeyRef

func (m *ComponentMetadataItem) GetSecretKeyRef() *ComponentSecretKeyRef

func (*ComponentMetadataItem) GetValue

func (m *ComponentMetadataItem) GetValue() string

func (*ComponentMetadataItem) ProtoMessage

func (*ComponentMetadataItem) ProtoMessage()

func (*ComponentMetadataItem) Reset

func (m *ComponentMetadataItem) Reset()

func (*ComponentMetadataItem) String

func (m *ComponentMetadataItem) String() string

func (*ComponentMetadataItem) XXX_DiscardUnknown

func (m *ComponentMetadataItem) XXX_DiscardUnknown()

func (*ComponentMetadataItem) XXX_Marshal

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

func (*ComponentMetadataItem) XXX_Merge

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

func (*ComponentMetadataItem) XXX_Size

func (m *ComponentMetadataItem) XXX_Size() int

func (*ComponentMetadataItem) XXX_Unmarshal

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

type ComponentSecretKeyRef

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

func (*ComponentSecretKeyRef) Descriptor

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

func (*ComponentSecretKeyRef) GetKey

func (m *ComponentSecretKeyRef) GetKey() string

func (*ComponentSecretKeyRef) GetName

func (m *ComponentSecretKeyRef) GetName() string

func (*ComponentSecretKeyRef) ProtoMessage

func (*ComponentSecretKeyRef) ProtoMessage()

func (*ComponentSecretKeyRef) Reset

func (m *ComponentSecretKeyRef) Reset()

func (*ComponentSecretKeyRef) String

func (m *ComponentSecretKeyRef) String() string

func (*ComponentSecretKeyRef) XXX_DiscardUnknown

func (m *ComponentSecretKeyRef) XXX_DiscardUnknown()

func (*ComponentSecretKeyRef) XXX_Marshal

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

func (*ComponentSecretKeyRef) XXX_Merge

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

func (*ComponentSecretKeyRef) XXX_Size

func (m *ComponentSecretKeyRef) XXX_Size() int

func (*ComponentSecretKeyRef) XXX_Unmarshal

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

type ComponentSpec

type ComponentSpec struct {
	Type                 string                   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Metadata             []*ComponentMetadataItem `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ComponentSpec) Descriptor

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

func (*ComponentSpec) GetMetadata

func (m *ComponentSpec) GetMetadata() []*ComponentMetadataItem

func (*ComponentSpec) GetType

func (m *ComponentSpec) GetType() string

func (*ComponentSpec) ProtoMessage

func (*ComponentSpec) ProtoMessage()

func (*ComponentSpec) Reset

func (m *ComponentSpec) Reset()

func (*ComponentSpec) String

func (m *ComponentSpec) String() string

func (*ComponentSpec) XXX_DiscardUnknown

func (m *ComponentSpec) XXX_DiscardUnknown()

func (*ComponentSpec) XXX_Marshal

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

func (*ComponentSpec) XXX_Merge

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

func (*ComponentSpec) XXX_Size

func (m *ComponentSpec) XXX_Size() int

func (*ComponentSpec) XXX_Unmarshal

func (m *ComponentSpec) 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)
	UpdateComponent(ctx context.Context, in *Component, opts ...grpc.CallOption) (*empty.Empty, 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)
	UpdateComponent(context.Context, *Component) (*empty.Empty, 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) CallLocal added in v0.2.0

func (*UnimplementedDaprInternalServer) UpdateComponent added in v0.2.0

func (*UnimplementedDaprInternalServer) UpdateComponent(ctx context.Context, req *Component) (*empty.Empty, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL