relation

package
v0.0.0-...-49c8f32 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2021 License: MIT Imports: 31 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-auth. DO NOT EDIT! source: block.proto

Package relation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: channel.proto

Package relation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: follow.proto

Package relation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: group.proto

Package relation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: include.proto

Code generated by protoc-gen-auth. DO NOT EDIT! source: inner_follow.proto

Package relation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: inner_group.proto

Package relation is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBlockHandler 

func RegisterBlockHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBlockHandler registers the http handlers for service Block to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBlockHandlerClient 

func RegisterBlockHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BlockClient) error

RegisterBlockHandlerClient registers the http handlers for service Block to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BlockClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BlockClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BlockClient" to call the correct interceptors.

func RegisterBlockHandlerFromEndpoint 

func RegisterBlockHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBlockHandlerFromEndpoint is same as RegisterBlockHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBlockHandlerServer 

func RegisterBlockHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BlockServer) error

RegisterBlockHandlerServer registers the http handlers for service Block to "mux". UnaryRPC :call BlockServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterBlockScopeServer 

func RegisterBlockScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv BlockServer) error

Register scoped server.

func RegisterBlockServer 

func RegisterBlockServer(s *grpc.Server, srv BlockServer)

func RegisterChannelHandler 

func RegisterChannelHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterChannelHandler registers the http handlers for service Channel to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterChannelHandlerClient 

func RegisterChannelHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChannelClient) error

RegisterChannelHandlerClient registers the http handlers for service Channel to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChannelClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChannelClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChannelClient" to call the correct interceptors.

func RegisterChannelHandlerFromEndpoint 

func RegisterChannelHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterChannelHandlerFromEndpoint is same as RegisterChannelHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterChannelHandlerServer 

func RegisterChannelHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChannelServer) error

RegisterChannelHandlerServer registers the http handlers for service Channel to "mux". UnaryRPC :call ChannelServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterChannelScopeServer 

func RegisterChannelScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv ChannelServer) error

Register scoped server.

func RegisterChannelServer 

func RegisterChannelServer(s *grpc.Server, srv ChannelServer)

func RegisterFollowHandler 

func RegisterFollowHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFollowHandler registers the http handlers for service Follow to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFollowHandlerClient 

func RegisterFollowHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FollowClient) error

RegisterFollowHandlerClient registers the http handlers for service Follow to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FollowClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FollowClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FollowClient" to call the correct interceptors.

func RegisterFollowHandlerFromEndpoint 

func RegisterFollowHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFollowHandlerFromEndpoint is same as RegisterFollowHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFollowHandlerServer 

func RegisterFollowHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FollowServer) error

RegisterFollowHandlerServer registers the http handlers for service Follow to "mux". UnaryRPC :call FollowServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterFollowScopeServer 

func RegisterFollowScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv FollowServer) error

Register scoped server.

func RegisterFollowServer 

func RegisterFollowServer(s *grpc.Server, srv FollowServer)

func RegisterGroupHandler 

func RegisterGroupHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterGroupHandler registers the http handlers for service Group to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterGroupHandlerClient 

func RegisterGroupHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GroupClient) error

RegisterGroupHandlerClient registers the http handlers for service Group to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "GroupClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "GroupClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "GroupClient" to call the correct interceptors.

func RegisterGroupHandlerFromEndpoint 

func RegisterGroupHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterGroupHandlerFromEndpoint is same as RegisterGroupHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterGroupHandlerServer 

func RegisterGroupHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GroupServer) error

RegisterGroupHandlerServer registers the http handlers for service Group to "mux". UnaryRPC :call GroupServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterGroupScopeServer 

func RegisterGroupScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv GroupServer) error

Register scoped server.

func RegisterGroupServer 

func RegisterGroupServer(s *grpc.Server, srv GroupServer)

func RegisterInnerFollowHandler 

func RegisterInnerFollowHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInnerFollowHandler registers the http handlers for service InnerFollow to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInnerFollowHandlerClient 

func RegisterInnerFollowHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InnerFollowClient) error

RegisterInnerFollowHandlerClient registers the http handlers for service InnerFollow to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InnerFollowClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InnerFollowClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InnerFollowClient" to call the correct interceptors.

func RegisterInnerFollowHandlerFromEndpoint 

func RegisterInnerFollowHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInnerFollowHandlerFromEndpoint is same as RegisterInnerFollowHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInnerFollowHandlerServer 

func RegisterInnerFollowHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InnerFollowServer) error

RegisterInnerFollowHandlerServer registers the http handlers for service InnerFollow to "mux". UnaryRPC :call InnerFollowServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInnerFollowScopeServer 

func RegisterInnerFollowScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv InnerFollowServer) error

Register scoped server.

func RegisterInnerFollowServer 

func RegisterInnerFollowServer(s *grpc.Server, srv InnerFollowServer)

func RegisterInnerGroupHandler 

func RegisterInnerGroupHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInnerGroupHandler registers the http handlers for service InnerGroup to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInnerGroupHandlerClient 

func RegisterInnerGroupHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InnerGroupClient) error

RegisterInnerGroupHandlerClient registers the http handlers for service InnerGroup to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InnerGroupClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InnerGroupClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InnerGroupClient" to call the correct interceptors.

func RegisterInnerGroupHandlerFromEndpoint 

func RegisterInnerGroupHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInnerGroupHandlerFromEndpoint is same as RegisterInnerGroupHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInnerGroupHandlerServer 

func RegisterInnerGroupHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InnerGroupServer) error

RegisterInnerGroupHandlerServer registers the http handlers for service InnerGroup to "mux". UnaryRPC :call InnerGroupServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInnerGroupScopeServer 

func RegisterInnerGroupScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv InnerGroupServer) error

Register scoped server.

func RegisterInnerGroupServer 

func RegisterInnerGroupServer(s *grpc.Server, srv InnerGroupServer)

Types

type ApplyRequest 

type ApplyRequest struct {
	Target               *uint64  `protobuf:"varint,1,req,name=target" json:"target,omitempty"`
	Reason               *string  `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Relation apply request.

func (*ApplyRequest) Descriptor 

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

func (*ApplyRequest) GetReason 

func (m *ApplyRequest) GetReason() string

func (*ApplyRequest) GetTarget 

func (m *ApplyRequest) GetTarget() uint64

func (*ApplyRequest) ProtoMessage 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) Reset 

func (m *ApplyRequest) Reset()

func (*ApplyRequest) String 

func (m *ApplyRequest) String() string

func (*ApplyRequest) Validate 

func (m *ApplyRequest) Validate() error

Validate checks the field values on ApplyRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ApplyRequest) XXX_DiscardUnknown 

func (m *ApplyRequest) XXX_DiscardUnknown()

func (*ApplyRequest) XXX_Marshal 

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

func (*ApplyRequest) XXX_Merge 

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

func (*ApplyRequest) XXX_Size 

func (m *ApplyRequest) XXX_Size() int

func (*ApplyRequest) XXX_Unmarshal 

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

type ApplyRequestValidationError 

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

ApplyRequestValidationError is the validation error returned by ApplyRequest.Validate if the designated constraints aren't met.

func (ApplyRequestValidationError) Cause 

func (e ApplyRequestValidationError) Cause() error

Cause function returns cause value.

func (ApplyRequestValidationError) Error 

func (e ApplyRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ApplyRequestValidationError) ErrorName 

func (e ApplyRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ApplyRequestValidationError) Field 

func (e ApplyRequestValidationError) Field() string

Field function returns field value.

func (ApplyRequestValidationError) Key 

func (e ApplyRequestValidationError) Key() bool

Key function returns key value.

func (ApplyRequestValidationError) Reason 

func (e ApplyRequestValidationError) Reason() string

Reason function returns reason value.

type BlockClient 

type BlockClient interface {
	// Block the specified account ID.
	Add(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*empty.Empty, error)
	// Unblock the specified account ID.
	Cancel(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*empty.Empty, error)
}

BlockClient is the client API for Block service.

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

func NewBlockClient 

func NewBlockClient(cc *grpc.ClientConn) BlockClient

type BlockServer 

type BlockServer interface {
	// Block the specified account ID.
	Add(context.Context, *common.UniqueId) (*empty.Empty, error)
	// Unblock the specified account ID.
	Cancel(context.Context, *common.UniqueId) (*empty.Empty, error)
}

BlockServer is the server API for Block service.

type ChannelClient 

type ChannelClient interface {
	// Follow channel.
	Add(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ChannelInfo, error)
	// Unfollow channel.
	Cancel(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*empty.Empty, error)
}

ChannelClient is the client API for Channel service.

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

func NewChannelClient 

func NewChannelClient(cc *grpc.ClientConn) ChannelClient

type ChannelInfo 

type ChannelInfo struct {
	Id                   *uint64              `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	Name                 *string              `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	Description          *string              `protobuf:"bytes,3,opt,name=description" json:"description,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,10,req,name=created_at,json=createdAt" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,11,req,name=updated_at,json=updatedAt" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Channel info.

func (*ChannelInfo) Descriptor 

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

func (*ChannelInfo) GetCreatedAt 

func (m *ChannelInfo) GetCreatedAt() *timestamp.Timestamp

func (*ChannelInfo) GetDescription 

func (m *ChannelInfo) GetDescription() string

func (*ChannelInfo) GetId 

func (m *ChannelInfo) GetId() uint64

func (*ChannelInfo) GetName 

func (m *ChannelInfo) GetName() string

func (*ChannelInfo) GetUpdatedAt 

func (m *ChannelInfo) GetUpdatedAt() *timestamp.Timestamp

func (*ChannelInfo) ProtoMessage 

func (*ChannelInfo) ProtoMessage()

func (*ChannelInfo) Reset 

func (m *ChannelInfo) Reset()

func (*ChannelInfo) String 

func (m *ChannelInfo) String() string

func (*ChannelInfo) Validate 

func (m *ChannelInfo) Validate() error

Validate checks the field values on ChannelInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ChannelInfo) XXX_DiscardUnknown 

func (m *ChannelInfo) XXX_DiscardUnknown()

func (*ChannelInfo) XXX_Marshal 

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

func (*ChannelInfo) XXX_Merge 

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

func (*ChannelInfo) XXX_Size 

func (m *ChannelInfo) XXX_Size() int

func (*ChannelInfo) XXX_Unmarshal 

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

type ChannelInfoValidationError 

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

ChannelInfoValidationError is the validation error returned by ChannelInfo.Validate if the designated constraints aren't met.

func (ChannelInfoValidationError) Cause 

func (e ChannelInfoValidationError) Cause() error

Cause function returns cause value.

func (ChannelInfoValidationError) Error 

func (e ChannelInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ChannelInfoValidationError) ErrorName 

func (e ChannelInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ChannelInfoValidationError) Field 

func (e ChannelInfoValidationError) Field() string

Field function returns field value.

func (ChannelInfoValidationError) Key 

func (e ChannelInfoValidationError) Key() bool

Key function returns key value.

func (ChannelInfoValidationError) Reason 

func (e ChannelInfoValidationError) Reason() string

Reason function returns reason value.

type ChannelServer 

type ChannelServer interface {
	// Follow channel.
	Add(context.Context, *ApplyRequest) (*ChannelInfo, error)
	// Unfollow channel.
	Cancel(context.Context, *common.UniqueId) (*empty.Empty, error)
}

ChannelServer is the server API for Channel service.

type FollowClient 

type FollowClient interface {
	// Add follow.
	Add(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Cancel follow.
	Cancel(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get account followings.
	GetFollowings(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*common.UniqueIds, error)
	// Get account followers.
	GetFollowers(ctx context.Context, in *common.PaginationIdRequest, opts ...grpc.CallOption) (*common.PaginationIdResponse, error)
	// Get account friends.
	GetFriends(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.UniqueIds, error)
}

FollowClient is the client API for Follow service.

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

func NewFollowClient 

func NewFollowClient(cc *grpc.ClientConn) FollowClient

type FollowServer 

type FollowServer interface {
	// Add follow.
	Add(context.Context, *ApplyRequest) (*empty.Empty, error)
	// Cancel follow.
	Cancel(context.Context, *common.UniqueId) (*empty.Empty, error)
	// Get account followings.
	GetFollowings(context.Context, *common.UniqueId) (*common.UniqueIds, error)
	// Get account followers.
	GetFollowers(context.Context, *common.PaginationIdRequest) (*common.PaginationIdResponse, error)
	// Get account friends.
	GetFriends(context.Context, *empty.Empty) (*common.UniqueIds, error)
}

FollowServer is the server API for Follow service.

type GroupClient 

type GroupClient interface {
	// Create group.
	Create(ctx context.Context, in *GroupInfo, opts ...grpc.CallOption) (*GroupInfo, error)
	// Get group info.
	Get(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*GroupInfo, error)
	// Update group info.
	Update(ctx context.Context, in *GroupInfo, opts ...grpc.CallOption) (*GroupInfo, error)
	// Add group members.
	Add(ctx context.Context, in *common.UniqueIds, opts ...grpc.CallOption) (*GroupInfo, error)
	// Kick group member.
	Remove(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*GroupInfo, error)
}

GroupClient is the client API for Group service.

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

func NewGroupClient 

func NewGroupClient(cc *grpc.ClientConn) GroupClient

type GroupInfo 

type GroupInfo struct {
	Id                   *uint64              `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Name                 *string              `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Notice               *string              `protobuf:"bytes,3,opt,name=notice" json:"notice,omitempty"`
	Members              []uint64             `protobuf:"varint,4,rep,name=members" json:"members,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Group info message type.

func (*GroupInfo) Descriptor 

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

func (*GroupInfo) GetCreatedAt 

func (m *GroupInfo) GetCreatedAt() *timestamp.Timestamp

func (*GroupInfo) GetId 

func (m *GroupInfo) GetId() uint64

func (*GroupInfo) GetMembers 

func (m *GroupInfo) GetMembers() []uint64

func (*GroupInfo) GetName 

func (m *GroupInfo) GetName() string

func (*GroupInfo) GetNotice 

func (m *GroupInfo) GetNotice() string

func (*GroupInfo) GetUpdatedAt 

func (m *GroupInfo) GetUpdatedAt() *timestamp.Timestamp

func (*GroupInfo) ProtoMessage 

func (*GroupInfo) ProtoMessage()

func (*GroupInfo) Reset 

func (m *GroupInfo) Reset()

func (*GroupInfo) String 

func (m *GroupInfo) String() string

func (*GroupInfo) Validate 

func (m *GroupInfo) Validate() error

Validate checks the field values on GroupInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*GroupInfo) XXX_DiscardUnknown 

func (m *GroupInfo) XXX_DiscardUnknown()

func (*GroupInfo) XXX_Marshal 

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

func (*GroupInfo) XXX_Merge 

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

func (*GroupInfo) XXX_Size 

func (m *GroupInfo) XXX_Size() int

func (*GroupInfo) XXX_Unmarshal 

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

type GroupInfoValidationError 

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

GroupInfoValidationError is the validation error returned by GroupInfo.Validate if the designated constraints aren't met.

func (GroupInfoValidationError) Cause 

func (e GroupInfoValidationError) Cause() error

Cause function returns cause value.

func (GroupInfoValidationError) Error 

func (e GroupInfoValidationError) Error() string

Error satisfies the builtin error interface

func (GroupInfoValidationError) ErrorName 

func (e GroupInfoValidationError) ErrorName() string

ErrorName returns error name.

func (GroupInfoValidationError) Field 

func (e GroupInfoValidationError) Field() string

Field function returns field value.

func (GroupInfoValidationError) Key 

func (e GroupInfoValidationError) Key() bool

Key function returns key value.

func (GroupInfoValidationError) Reason 

func (e GroupInfoValidationError) Reason() string

Reason function returns reason value.

type GroupServer 

type GroupServer interface {
	// Create group.
	Create(context.Context, *GroupInfo) (*GroupInfo, error)
	// Get group info.
	Get(context.Context, *common.UniqueId) (*GroupInfo, error)
	// Update group info.
	Update(context.Context, *GroupInfo) (*GroupInfo, error)
	// Add group members.
	Add(context.Context, *common.UniqueIds) (*GroupInfo, error)
	// Kick group member.
	Remove(context.Context, *common.UniqueId) (*GroupInfo, error)
}

GroupServer is the server API for Group service.

type InnerFollowClient 

type InnerFollowClient interface {
	// Check following.
	IsFollowing(ctx context.Context, in *common.UniqueIds, opts ...grpc.CallOption) (*StatusResponse, error)
	// Check friends.
	IsFriends(ctx context.Context, in *common.UniqueIds, opts ...grpc.CallOption) (*StatusResponse, error)
}

InnerFollowClient is the client API for InnerFollow service.

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

func NewInnerFollowClient 

func NewInnerFollowClient(cc *grpc.ClientConn) InnerFollowClient

type InnerFollowServer 

type InnerFollowServer interface {
	// Check following.
	IsFollowing(context.Context, *common.UniqueIds) (*StatusResponse, error)
	// Check friends.
	IsFriends(context.Context, *common.UniqueIds) (*StatusResponse, error)
}

InnerFollowServer is the server API for InnerFollow service.

type InnerGroupClient 

type InnerGroupClient interface {
	// Get group members.
	GetMembers(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*common.UniqueIds, error)
	// Check is group members.
	IsMembers(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

InnerGroupClient is the client API for InnerGroup service.

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

func NewInnerGroupClient 

func NewInnerGroupClient(cc *grpc.ClientConn) InnerGroupClient

type InnerGroupServer 

type InnerGroupServer interface {
	// Get group members.
	GetMembers(context.Context, *common.UniqueId) (*common.UniqueIds, error)
	// Check is group members.
	IsMembers(context.Context, *StatusRequest) (*StatusResponse, error)
}

InnerGroupServer is the server API for InnerGroup service.

type StatusRequest 

type StatusRequest struct {
	Target               *uint64  `protobuf:"varint,1,req,name=target" json:"target,omitempty"`
	Ids                  []uint64 `protobuf:"varint,2,rep,name=ids" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Relation status request.

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) GetIds 

func (m *StatusRequest) GetIds() []uint64

func (*StatusRequest) GetTarget 

func (m *StatusRequest) GetTarget() uint64

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) Validate 

func (m *StatusRequest) Validate() error

Validate checks the field values on StatusRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusRequestValidationError 

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

StatusRequestValidationError is the validation error returned by StatusRequest.Validate if the designated constraints aren't met.

func (StatusRequestValidationError) Cause 

func (e StatusRequestValidationError) Cause() error

Cause function returns cause value.

func (StatusRequestValidationError) Error 

func (e StatusRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StatusRequestValidationError) ErrorName 

func (e StatusRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StatusRequestValidationError) Field 

func (e StatusRequestValidationError) Field() string

Field function returns field value.

func (StatusRequestValidationError) Key 

func (e StatusRequestValidationError) Key() bool

Key function returns key value.

func (StatusRequestValidationError) Reason 

func (e StatusRequestValidationError) Reason() string

Reason function returns reason value.

type StatusResponse 

type StatusResponse struct {
	State                map[uint64]bool `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Relation status response.

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetState 

func (m *StatusResponse) GetState() map[uint64]bool

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) Validate 

func (m *StatusResponse) Validate() error

Validate checks the field values on StatusResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type StatusResponseValidationError 

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

StatusResponseValidationError is the validation error returned by StatusResponse.Validate if the designated constraints aren't met.

func (StatusResponseValidationError) Cause 

func (e StatusResponseValidationError) Cause() error

Cause function returns cause value.

func (StatusResponseValidationError) Error 

func (e StatusResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StatusResponseValidationError) ErrorName 

func (e StatusResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StatusResponseValidationError) Field 

func (e StatusResponseValidationError) Field() string

Field function returns field value.

func (StatusResponseValidationError) Key 

func (e StatusResponseValidationError) Key() bool

Key function returns key value.

func (StatusResponseValidationError) Reason 

func (e StatusResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedBlockServer 

type UnimplementedBlockServer struct {
}

UnimplementedBlockServer can be embedded to have forward compatible implementations.

func (*UnimplementedBlockServer) Add 

func (*UnimplementedBlockServer) Add(ctx context.Context, req *common.UniqueId) (*empty.Empty, error)

func (*UnimplementedBlockServer) Cancel 

func (*UnimplementedBlockServer) Cancel(ctx context.Context, req *common.UniqueId) (*empty.Empty, error)

type UnimplementedChannelServer 

type UnimplementedChannelServer struct {
}

UnimplementedChannelServer can be embedded to have forward compatible implementations.

func (*UnimplementedChannelServer) Add 

func (*UnimplementedChannelServer) Add(ctx context.Context, req *ApplyRequest) (*ChannelInfo, error)

func (*UnimplementedChannelServer) Cancel 

func (*UnimplementedChannelServer) Cancel(ctx context.Context, req *common.UniqueId) (*empty.Empty, error)

type UnimplementedFollowServer 

type UnimplementedFollowServer struct {
}

UnimplementedFollowServer can be embedded to have forward compatible implementations.

func (*UnimplementedFollowServer) Add 

func (*UnimplementedFollowServer) Add(ctx context.Context, req *ApplyRequest) (*empty.Empty, error)

func (*UnimplementedFollowServer) Cancel 

func (*UnimplementedFollowServer) Cancel(ctx context.Context, req *common.UniqueId) (*empty.Empty, error)

func (*UnimplementedFollowServer) GetFollowers 

func (*UnimplementedFollowServer) GetFollowers(ctx context.Context, req *common.PaginationIdRequest) (*common.PaginationIdResponse, error)

func (*UnimplementedFollowServer) GetFollowings 

func (*UnimplementedFollowServer) GetFollowings(ctx context.Context, req *common.UniqueId) (*common.UniqueIds, error)

func (*UnimplementedFollowServer) GetFriends 

func (*UnimplementedFollowServer) GetFriends(ctx context.Context, req *empty.Empty) (*common.UniqueIds, error)

type UnimplementedGroupServer 

type UnimplementedGroupServer struct {
}

UnimplementedGroupServer can be embedded to have forward compatible implementations.

func (*UnimplementedGroupServer) Add 

func (*UnimplementedGroupServer) Add(ctx context.Context, req *common.UniqueIds) (*GroupInfo, error)

func (*UnimplementedGroupServer) Create 

func (*UnimplementedGroupServer) Create(ctx context.Context, req *GroupInfo) (*GroupInfo, error)

func (*UnimplementedGroupServer) Get 

func (*UnimplementedGroupServer) Get(ctx context.Context, req *common.UniqueId) (*GroupInfo, error)

func (*UnimplementedGroupServer) Remove 

func (*UnimplementedGroupServer) Remove(ctx context.Context, req *common.UniqueId) (*GroupInfo, error)

func (*UnimplementedGroupServer) Update 

func (*UnimplementedGroupServer) Update(ctx context.Context, req *GroupInfo) (*GroupInfo, error)

type UnimplementedInnerFollowServer 

type UnimplementedInnerFollowServer struct {
}

UnimplementedInnerFollowServer can be embedded to have forward compatible implementations.

func (*UnimplementedInnerFollowServer) IsFollowing 

func (*UnimplementedInnerFollowServer) IsFollowing(ctx context.Context, req *common.UniqueIds) (*StatusResponse, error)

func (*UnimplementedInnerFollowServer) IsFriends 

func (*UnimplementedInnerFollowServer) IsFriends(ctx context.Context, req *common.UniqueIds) (*StatusResponse, error)

type UnimplementedInnerGroupServer 

type UnimplementedInnerGroupServer struct {
}

UnimplementedInnerGroupServer can be embedded to have forward compatible implementations.

func (*UnimplementedInnerGroupServer) GetMembers 

func (*UnimplementedInnerGroupServer) GetMembers(ctx context.Context, req *common.UniqueId) (*common.UniqueIds, error)

func (*UnimplementedInnerGroupServer) IsMembers 

func (*UnimplementedInnerGroupServer) IsMembers(ctx context.Context, req *StatusRequest) (*StatusResponse, 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.