identityrepoproto

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthIdentityrepo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIdentityrepo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIdentityrepo = fmt.Errorf("proto: unexpected end of group")
)

Functions

func DRPCRegisterIdentityRepo 

func DRPCRegisterIdentityRepo(mux drpc.Mux, impl DRPCIdentityRepoServer) error

Types

type DRPCIdentityRepoClient 

type DRPCIdentityRepoClient interface {
	DRPCConn() drpc.Conn

	DataPut(ctx context.Context, in *DataPutRequest) (*Ok, error)
	DataDelete(ctx context.Context, in *DataDeleteRequest) (*Ok, error)
	DataPull(ctx context.Context, in *DataPullRequest) (*DataPullResponse, error)
}

func NewDRPCIdentityRepoClient 

func NewDRPCIdentityRepoClient(cc drpc.Conn) DRPCIdentityRepoClient

type DRPCIdentityRepoDescription 

type DRPCIdentityRepoDescription struct{}

func (DRPCIdentityRepoDescription) Method 

func (DRPCIdentityRepoDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCIdentityRepoDescription) NumMethods 

func (DRPCIdentityRepoDescription) NumMethods() int

type DRPCIdentityRepoServer 

type DRPCIdentityRepoServer interface {
	DataPut(context.Context, *DataPutRequest) (*Ok, error)
	DataDelete(context.Context, *DataDeleteRequest) (*Ok, error)
	DataPull(context.Context, *DataPullRequest) (*DataPullResponse, error)
}

type DRPCIdentityRepoUnimplementedServer 

type DRPCIdentityRepoUnimplementedServer struct{}

func (*DRPCIdentityRepoUnimplementedServer) DataDelete 

func (s *DRPCIdentityRepoUnimplementedServer) DataDelete(context.Context, *DataDeleteRequest) (*Ok, error)

func (*DRPCIdentityRepoUnimplementedServer) DataPull 

func (s *DRPCIdentityRepoUnimplementedServer) DataPull(context.Context, *DataPullRequest) (*DataPullResponse, error)

func (*DRPCIdentityRepoUnimplementedServer) DataPut 

func (s *DRPCIdentityRepoUnimplementedServer) DataPut(context.Context, *DataPutRequest) (*Ok, error)

type DRPCIdentityRepo_DataDeleteStream 

type DRPCIdentityRepo_DataDeleteStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type DRPCIdentityRepo_DataPullStream 

type DRPCIdentityRepo_DataPullStream interface {
	drpc.Stream
	SendAndClose(*DataPullResponse) error
}

type DRPCIdentityRepo_DataPutStream 

type DRPCIdentityRepo_DataPutStream interface {
	drpc.Stream
	SendAndClose(*Ok) error
}

type Data 

type Data struct {
	// kind is a string representing the kind of data
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// data is a byte payload
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// data signature
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*Data) Descriptor 

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

func (*Data) GetData 

func (m *Data) GetData() []byte

func (*Data) GetKind 

func (m *Data) GetKind() string

func (*Data) GetSignature 

func (m *Data) GetSignature() []byte

func (*Data) Marshal 

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

func (*Data) MarshalTo 

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

func (*Data) MarshalToSizedBuffer 

func (m *Data) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) Size 

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

func (*Data) String 

func (m *Data) String() string

func (*Data) Unmarshal 

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

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

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

func (*Data) XXX_Merge 

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

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

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

type DataDeleteRequest 

type DataDeleteRequest struct {
	// string representation of identity, must be equal handshake result
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// kinds of data to delete, if empty all kinds will be deleted
	Kinds []string `protobuf:"bytes,2,rep,name=kinds,proto3" json:"kinds,omitempty"`
}

func (*DataDeleteRequest) Descriptor 

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

func (*DataDeleteRequest) GetIdentity 

func (m *DataDeleteRequest) GetIdentity() string

func (*DataDeleteRequest) GetKinds 

func (m *DataDeleteRequest) GetKinds() []string

func (*DataDeleteRequest) Marshal 

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

func (*DataDeleteRequest) MarshalTo 

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

func (*DataDeleteRequest) MarshalToSizedBuffer 

func (m *DataDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataDeleteRequest) ProtoMessage 

func (*DataDeleteRequest) ProtoMessage()

func (*DataDeleteRequest) Reset 

func (m *DataDeleteRequest) Reset()

func (*DataDeleteRequest) Size 

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

func (*DataDeleteRequest) String 

func (m *DataDeleteRequest) String() string

func (*DataDeleteRequest) Unmarshal 

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

func (*DataDeleteRequest) XXX_DiscardUnknown 

func (m *DataDeleteRequest) XXX_DiscardUnknown()

func (*DataDeleteRequest) XXX_Marshal 

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

func (*DataDeleteRequest) XXX_Merge 

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

func (*DataDeleteRequest) XXX_Size 

func (m *DataDeleteRequest) XXX_Size() int

func (*DataDeleteRequest) XXX_Unmarshal 

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

type DataPullRequest 

type DataPullRequest struct {
	// list of identities wanted to request
	Identities []string `protobuf:"bytes,1,rep,name=identities,proto3" json:"identities,omitempty"`
	// kinds of data wanted to request
	Kinds []string `protobuf:"bytes,2,rep,name=kinds,proto3" json:"kinds,omitempty"`
}

func (*DataPullRequest) Descriptor 

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

func (*DataPullRequest) GetIdentities 

func (m *DataPullRequest) GetIdentities() []string

func (*DataPullRequest) GetKinds 

func (m *DataPullRequest) GetKinds() []string

func (*DataPullRequest) Marshal 

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

func (*DataPullRequest) MarshalTo 

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

func (*DataPullRequest) MarshalToSizedBuffer 

func (m *DataPullRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPullRequest) ProtoMessage 

func (*DataPullRequest) ProtoMessage()

func (*DataPullRequest) Reset 

func (m *DataPullRequest) Reset()

func (*DataPullRequest) Size 

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

func (*DataPullRequest) String 

func (m *DataPullRequest) String() string

func (*DataPullRequest) Unmarshal 

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

func (*DataPullRequest) XXX_DiscardUnknown 

func (m *DataPullRequest) XXX_DiscardUnknown()

func (*DataPullRequest) XXX_Marshal 

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

func (*DataPullRequest) XXX_Merge 

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

func (*DataPullRequest) XXX_Size 

func (m *DataPullRequest) XXX_Size() int

func (*DataPullRequest) XXX_Unmarshal 

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

type DataPullResponse 

type DataPullResponse struct {
	Data []*DataWithIdentity `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
}

func (*DataPullResponse) Descriptor 

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

func (*DataPullResponse) GetData 

func (m *DataPullResponse) GetData() []*DataWithIdentity

func (*DataPullResponse) Marshal 

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

func (*DataPullResponse) MarshalTo 

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

func (*DataPullResponse) MarshalToSizedBuffer 

func (m *DataPullResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPullResponse) ProtoMessage 

func (*DataPullResponse) ProtoMessage()

func (*DataPullResponse) Reset 

func (m *DataPullResponse) Reset()

func (*DataPullResponse) Size 

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

func (*DataPullResponse) String 

func (m *DataPullResponse) String() string

func (*DataPullResponse) Unmarshal 

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

func (*DataPullResponse) XXX_DiscardUnknown 

func (m *DataPullResponse) XXX_DiscardUnknown()

func (*DataPullResponse) XXX_Marshal 

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

func (*DataPullResponse) XXX_Merge 

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

func (*DataPullResponse) XXX_Size 

func (m *DataPullResponse) XXX_Size() int

func (*DataPullResponse) XXX_Unmarshal 

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

type DataPutRequest 

type DataPutRequest struct {
	// string representation of identity, must be equal handshake result
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// data to save
	Data []*Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
}

func (*DataPutRequest) Descriptor 

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

func (*DataPutRequest) GetData 

func (m *DataPutRequest) GetData() []*Data

func (*DataPutRequest) GetIdentity 

func (m *DataPutRequest) GetIdentity() string

func (*DataPutRequest) Marshal 

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

func (*DataPutRequest) MarshalTo 

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

func (*DataPutRequest) MarshalToSizedBuffer 

func (m *DataPutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataPutRequest) ProtoMessage 

func (*DataPutRequest) ProtoMessage()

func (*DataPutRequest) Reset 

func (m *DataPutRequest) Reset()

func (*DataPutRequest) Size 

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

func (*DataPutRequest) String 

func (m *DataPutRequest) String() string

func (*DataPutRequest) Unmarshal 

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

func (*DataPutRequest) XXX_DiscardUnknown 

func (m *DataPutRequest) XXX_DiscardUnknown()

func (*DataPutRequest) XXX_Marshal 

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

func (*DataPutRequest) XXX_Merge 

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

func (*DataPutRequest) XXX_Size 

func (m *DataPutRequest) XXX_Size() int

func (*DataPutRequest) XXX_Unmarshal 

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

type DataWithIdentity 

type DataWithIdentity struct {
	Identity string  `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Data     []*Data `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
}

func (*DataWithIdentity) Descriptor 

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

func (*DataWithIdentity) GetData 

func (m *DataWithIdentity) GetData() []*Data

func (*DataWithIdentity) GetIdentity 

func (m *DataWithIdentity) GetIdentity() string

func (*DataWithIdentity) Marshal 

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

func (*DataWithIdentity) MarshalTo 

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

func (*DataWithIdentity) MarshalToSizedBuffer 

func (m *DataWithIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataWithIdentity) ProtoMessage 

func (*DataWithIdentity) ProtoMessage()

func (*DataWithIdentity) Reset 

func (m *DataWithIdentity) Reset()

func (*DataWithIdentity) Size 

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

func (*DataWithIdentity) String 

func (m *DataWithIdentity) String() string

func (*DataWithIdentity) Unmarshal 

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

func (*DataWithIdentity) XXX_DiscardUnknown 

func (m *DataWithIdentity) XXX_DiscardUnknown()

func (*DataWithIdentity) XXX_Marshal 

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

func (*DataWithIdentity) XXX_Merge 

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

func (*DataWithIdentity) XXX_Size 

func (m *DataWithIdentity) XXX_Size() int

func (*DataWithIdentity) XXX_Unmarshal 

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

type Ok 

type Ok struct {
}

func (*Ok) Descriptor 

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

func (*Ok) Marshal 

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

func (*Ok) MarshalTo 

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

func (*Ok) MarshalToSizedBuffer 

func (m *Ok) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ok) ProtoMessage 

func (*Ok) ProtoMessage()

func (*Ok) Reset 

func (m *Ok) Reset()

func (*Ok) Size 

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

func (*Ok) String 

func (m *Ok) String() string

func (*Ok) Unmarshal 

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

func (*Ok) XXX_DiscardUnknown 

func (m *Ok) XXX_DiscardUnknown()

func (*Ok) XXX_Marshal 

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

func (*Ok) XXX_Merge 

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

func (*Ok) XXX_Size 

func (m *Ok) XXX_Size() int

func (*Ok) XXX_Unmarshal 

func (m *Ok) XXX_Unmarshal(b []byte) 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.