service

Documentation

Overview

* Copyright 2018 Johannes Donath <johannesd@torchmind.com> * and other copyright owners as documented in the project's IP log. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2018 Johannes Donath <johannesd@torchmind.com> * and other copyright owners as documented in the project's IP log. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2018 Johannes Donath <johannesd@torchmind.com> * and other copyright owners as documented in the project's IP log. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2018 Johannes Donath <johannesd@torchmind.com> * and other copyright owners as documented in the project's IP log. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2018 Johannes Donath <johannesd@torchmind.com> * and other copyright owners as documented in the project's IP log. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• type EventServiceImpl
  • func NewEventService(cache *cache.Cache) *EventServiceImpl
  • func (s *EventServiceImpl) StreamEvents(_ *empty.Empty, srv rpc.EventService_StreamEventsServer) error
• type ProfileServiceImpl
  • func NewProfileService(cache *cache.Cache) *ProfileServiceImpl
  • func (s *ProfileServiceImpl) BulkGetId(_ context.Context, req *rpc.BulkIdRequest) (*rpc.BulkIdResponse, error)
  • func (s *ProfileServiceImpl) GetId(_ context.Context, req *rpc.GetIdRequest) (*rpc.ProfileId, error)
  • func (s *ProfileServiceImpl) GetNameHistory(_ context.Context, req *rpc.IdRequest) (*rpc.NameHistory, error)
  • func (s *ProfileServiceImpl) GetProfile(_ context.Context, req *rpc.IdRequest) (*rpc.Profile, error)
• type Server
  • func NewServer(plugin *plugin.Manager, cache *cache.Cache) (*Server, error)
  • func (s *Server) Destroy()
  • func (s *Server) Listen(listener net.Listener)
  • func (s *Server) Stop()
• type ServerServiceImpl
  • func NewServerService(cache *cache.Cache) *ServerServiceImpl
  • func (s *ServerServiceImpl) CheckBlacklist(_ context.Context, req *rpc.CheckBlacklistRequest) (*rpc.CheckBlacklistResponse, error)
  • func (s *ServerServiceImpl) GetBlacklist(context.Context, *empty.Empty) (*rpc.Blacklist, error)
  • func (s *ServerServiceImpl) Login(_ context.Context, req *rpc.LoginRequest) (*rpc.Profile, error)
• type SystemServiceImpl
  • func NewSystemService(plugin *plugin.Manager) *SystemServiceImpl
  • func (s *SystemServiceImpl) GetPlugins(context.Context, *empty.Empty) (*rpc.PluginList, error)
  • func (s *SystemServiceImpl) GetStatus(context.Context, *empty.Empty) (*rpc.Status, error)

Types

type EventServiceImpl

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

func NewEventService

func NewEventService(cache *cache.Cache) *EventServiceImpl

func (*EventServiceImpl) StreamEvents

func (s *EventServiceImpl) StreamEvents(_ *empty.Empty, srv rpc.EventService_StreamEventsServer) error

type ProfileServiceImpl

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

func NewProfileService

func NewProfileService(cache *cache.Cache) *ProfileServiceImpl

func (*ProfileServiceImpl) BulkGetId

func (s *ProfileServiceImpl) BulkGetId(_ context.Context, req *rpc.BulkIdRequest) (*rpc.BulkIdResponse, error)

func (*ProfileServiceImpl) GetId

func (s *ProfileServiceImpl) GetId(_ context.Context, req *rpc.GetIdRequest) (*rpc.ProfileId, error)

func (*ProfileServiceImpl) GetNameHistory

func (s *ProfileServiceImpl) GetNameHistory(_ context.Context, req *rpc.IdRequest) (*rpc.NameHistory, error)

func (*ProfileServiceImpl) GetProfile

func (s *ProfileServiceImpl) GetProfile(_ context.Context, req *rpc.IdRequest) (*rpc.Profile, error)

type Server

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

Represents an RPC server

func NewServer

func NewServer(plugin *plugin.Manager, cache *cache.Cache) (*Server, error)

Constructs a new RPC server instance and starts it

func (*Server) Destroy

func (s *Server) Destroy()

destroys the server instance permanently

func (*Server) Listen

func (s *Server) Listen(listener net.Listener)

Starts listening on an arbitrary socket

func (*Server) Stop

func (s *Server) Stop()

Stops listening

type ServerServiceImpl

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

func NewServerService

func NewServerService(cache *cache.Cache) *ServerServiceImpl

func (*ServerServiceImpl) CheckBlacklist

func (s *ServerServiceImpl) CheckBlacklist(_ context.Context, req *rpc.CheckBlacklistRequest) (*rpc.CheckBlacklistResponse, error)

func (*ServerServiceImpl) GetBlacklist

func (s *ServerServiceImpl) GetBlacklist(context.Context, *empty.Empty) (*rpc.Blacklist, error)

func (*ServerServiceImpl) Login

func (s *ServerServiceImpl) Login(_ context.Context, req *rpc.LoginRequest) (*rpc.Profile, error)

type SystemServiceImpl

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

func NewSystemService

func NewSystemService(plugin *plugin.Manager) *SystemServiceImpl

func (*SystemServiceImpl) GetPlugins

func (s *SystemServiceImpl) GetPlugins(context.Context, *empty.Empty) (*rpc.PluginList, error)

func (*SystemServiceImpl) GetStatus

func (s *SystemServiceImpl) GetStatus(context.Context, *empty.Empty) (*rpc.Status, error)